I have an application that is currently running and is using Rx Streams to
move data. Now in this application, I have a couple of streams whose
messages I would like to write to a single Kafka topic. Given this, I have
say Streams 1 to 5 as below:

Stream1 - Takes in DataType A Stream2 - Takes in DataType B and so on

Where these Streams are Rx Observers. All these data types that I get out
of the stream are converted to a common JSON structure. I want this JSON
structure to be pushed to a single Kafka topic.

Now the questions are:

   1.

   Should I create one KafkaProducer for each of those Streams or rather Rx
   Observer instances?
   2.

   What happens if multiple threads using its own instance of a
   KafkaProducer to write to the same topic?

Reply via email to