2017-01-26 13 views
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")、
しかし、私はそれを行う方法がわかりません 助けてくれてありがとう

答えて

1

コンセプト「消費者団体」は消費者にのみ適用されます(名前が示すように)。あなたがカフカにメッセージを書くと、どんな消費者グループも後でそのメッセージを読むことができます。

したがって、メッセージを書き込むと、消費者グループを指定することは意味をなさないため不可能です。