如何在java中将消费者组添加到消息中？答案

【问题标题】：How to add consumer group to message in java?如何在java中将消费者组添加到消息中？
【发布时间】：2017-09-22 14:55:31
【问题描述】：

我是 java、spring 和 kafka 的新手
我有下一个发送消息的代码

kafkaTemplate.send(topic, message);

我的生产者配置：

 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);

我想向我的消费者组发送消息（例如“MyConsumerGroup”），
但我不知道我该怎么做感谢帮助

【问题讨论】：

标签： java spring kafka-producer-api

【解决方案1】：

“消费者群体”的概念仅适用于消费者（顾名思义）。如果您向 Kafka 写入消息，任何消费者组都可以稍后读取该消息。

因此，如果您编写消息，则无法指定消费者组，因为这没有任何意义。

【讨论】：