Tüketici grubunu java mesajına nasıl ekleyebilirim?

Question

Ben mesaj göndermek için bir sonraki kod var java, ilkbahar ve kafka
yeniyim

kafkaTemplate.send(topic, message); 

yapımcı My yapılandırma:

props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, 
      bootstrapServers); 
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, 
      IntegerSerializer.class); 
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, 
      StringSerializer.class); 
    // value to block, after which it will throw a TimeoutException 
    props.put(ProducerConfig.MAX_BLOCK_MS_CONFIG, 5000); 

benim tüketici grubuyla mesaj göndermek istiyorum (örneğin "MyConsumerGroup"),
ama nasıl yapılacağını bilmiyorum

Answer 1

Konsept "Tüketici grupları" nın sadece tüketiciler için geçerlidir (adından da anlaşılacağı gibi). Kafka'ya bir mesaj yazarsanız, herhangi bir tüketici grubu mesajı daha sonra okuyabilir. Bu nedenle, bir mesaj yazarsanız, bir tüketici grubu belirtmek mümkün değildir, çünkü bu bir anlam ifade etmemektedir.