Eu sou novato em kafka. Criei exemplos de programas de produtores e grupos de consumidores do kafka sync usando o kafka_2.9.2-0.8.1.1. Portanto, minha pergunta é: preciso adicionar código multithreading ao produtor (como a classe consumergroup) para oferecer suporte a um grande número de solicitações? Eu li que o método de envio do produtor é seguro para threads. Então o produtor kafka cuidará dos conceitos multithreading internamente ou o desenvolvedor precisará codificar explicitamente?

Qualquer ajuda seria muito apreciada.

Obrigado, Cdhar