Q

Kstreamsメッセージの特定のキーに基づいて分割された方法でkafkaに書き込む方法

2017-06-30 4 views 0 likes

0

kstreamsの高レベルDSLではtoメソッドを使用していますが、出力を分割方法でkafkaに書き込む出力メッセージのキーにKstreamsメッセージの特定のキーに基づいて分割された方法でkafkaに書き込む方法

2017-06-30 Raghvendra Singh

A

答えて

2

出力レコードは、デフォルトでキーによってパーティション化されます。また、あなたがに（）メソッドのこのオーバーロードすることにより、独自のパーティショナを提供することができます。

void to(StreamPartitioner<? super K,? super V> partitioner, 
    String topic)

http://kafka.apache.org/0110/javadoc/org/apache/kafka/streams/kstream/KStream.html#to(org.apache.kafka.streams.processor.StreamPartitioner,%20java.lang.String)

2017-07-01 12:09:06

+0

APIを検索しながら、私はこれをしようとするおかげで、何とか私はそれを逃しました –

関連する問題