Я просто изучаю Kafka
, в настоящее время я использую одну тему producer
и одну для создания сообщений, и она используется одним Consumer
. очень просто.
Я читал страницу Kafka, new Producer API is thread-safe
и совместное использование одного экземпляра улучшат производительность.
Означает ли это, что я могу использовать одного производителя для публикации сообщений в нескольких темах?
KafkaProducer<K,V>
, см. предложение. Примеры использования производителя приведены в javadocs.. На этой странице есть пример кода, показывающий, как можно определить целевую тему при отправке сообщение. Извините, если я был недостаточно ясен. - person Michael G. Noll   schedule 24.08.2016