You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
This repository has been archived by the owner on Jul 22, 2020. It is now read-only.
We need to implement an Akka actor that publish messages to Kafka in Akka Stream context.
In order to make this work, it is expected to create a producer manager that instructs a producer actor to publish messages into Kafka.
As a starting point, we can simplify the publishing scenario and write String-based messages, and use no Key. We can add keyed-based messages, and use Avro for encoding in future tasks.
It is needed to create create a Main app in the demo module to show how the new created artifacts work.
The text was updated successfully, but these errors were encountered:
We need to implement an Akka actor that publish messages to Kafka in Akka Stream context.
In order to make this work, it is expected to create a producer manager that instructs a producer actor to publish messages into Kafka.
As a starting point, we can simplify the publishing scenario and write String-based messages, and use no Key. We can add keyed-based messages, and use Avro for encoding in future tasks.
It is needed to create create a Main app in the demo module to show how the new created artifacts work.
The text was updated successfully, but these errors were encountered: