Version 7 of Kafka allowed to send messages to multiple topics within one request. I assume I can do samething in version 8, am I correct? Does my code piece look correct? List<KeyedMessage<String, String>> topicsMsgsList = new ArrayList(); KeyedMessage<String, String> data1 = new KeyedMessage<String, String>(topic1, msg); KeyedMessage<String, String> data2 = new KeyedMessage<String, String>(topic2, msg); topicsMsgsList.add(data1); topicsMsgsList.add(data2); producer.send( topicsMsgsList );
Thanks, Vadim