В большом объеме в реальном времени Java-приложение ям отправка сообщений наапач кафка, В настоящее время я 'Я отправляю сообщения в одну тему, но в будущем мне может понадобиться отправить сообщения в несколько тем.

В этом случае яНе уверен, что погода создаст продюсера для каждой темы, или мне следует использовать одного продюсера для всех моих тем?

Вот мой код:

props = new Properties();
props.put("zk.connect", :,:,:);
props.put("zk.connectiontimeout.ms", "1000000");
props.put("producer.type", "async");

Producer producer = new kafka.javaapi.producer.Producer(new ProducerConfig(props));

ProducerData producerData1 = new ProducerData("someTopic1", messageTosend);
ProducerData producerData2 = new ProducerData("someTopic2", messageTosend);

producer.send(producerData1);
producer.send(producerData2);

Как видите, после создания продюсера я могу использовать его для отправки данных в разные темы. Интересно, что является лучшей практикой? Если мое приложение отправляет несколько тем (каждая тема получает разные данные), могу ли / должен ли я использовать одного производителя или мне нужно создать несколько производителей? Когда (вообще говоря) я должен использовать более одного производителя?