在kstreams高级dsl中，我们有to方法，如果我们想根据输出消息中的一个键，以分区的方式将输出写入kafka，有没有方法。
kqqjbcuj1#
默认情况下，输出记录按键进行分区。此外，您还可以通过to（）方法的此重载提供自己的分区器：
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）
1条答案
按热度按时间kqqjbcuj1#
默认情况下，输出记录按键进行分区。此外，您还可以通过to（）方法的此重载提供自己的分区器：
http://kafka.apache.org/0110/javadoc/org/apache/kafka/streams/kstream/kstream.html#to（org.apache.kafka.streams.processor.streampartitioner，%20java.lang.string）