Apache Kafka（KStreams）：如何订阅多个主题？

Question

我有以下代码

//Kafka Config setup
Properties props = ...; //setup

List<String> topicList = Arrays.asList({"A", "B", "C"});

StreamBuilder builder = new StreamBuilder();
KStream<String, String> source = builder.stream(topicList);

source
.map((k,v) -> { //busy code for mapping data})
.transformValues(new MyGenericTransformer());
.to((k,v,r) -> {//busy code for topic routing});

new KafkaStream(builder.build(), properties).start();

我的问题：当我添加多个主题订阅时（即上面的A，B，C），Kstream代码停止接收记录。

参考文献：https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/StreamsBuilder.html

相关文件

public <K,V> KStream<K,V> stream(java.util.Collection<java.lang.String> topics)

"If multiple topics are specified there is no ordering guarantee for records from different topics."

我想实现的是：让一个Kstream（即上面的“源”）消耗/处理多个主题。

Answer 1

主题是否共享同一个键？

请注意，指定的输入主题必须按键分区。如果不是这样，用户有责任在任何基于键的操作（如聚合或连接）应用于返回的KStream之前重新分区数据。

这可能是你的拦截器。

另一个可能的问题可能是消费者群体使用的。