8
は、私は、メッセージを送信するために、私は次のコードを持っているのjava、春とカフカ
で新たなんだJavaでメッセージにコンシューマグループを追加するには?
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")、
しかし、私はそれを行う方法がわかりません 助けてくれてありがとう