Kafka流媒体API:KStream到Ktable 1

Question

我有一个带有3个经纪人的群集kafka，我有300个主题。

我想与他人独立地使用API KAFKA流进行处理，并将每个输入主题的结果写入特定主题

inputtopic1 to outputtopic1 
inputtopic2  to outputtopic2
inputtopic3 to outputtopic3
inputtopic4 to outputtopic4 

etc

有什么想法？

Answer 1

http://docs.confluent.io/current/current/streams/developer-guide.html#writing-streams-treams-back-to-kafka

to(( ->终端操作。将记录写入Kafka主题。(kStream详细信息，ktable详细信息(

何时明确提供Serdes：

如果您不明确指定Serdes，则使用配置中的默认SERD。如果KSTREAM或KTABLE的键和/或值类型不匹配配置的默认Serd，则必须明确特定。有关配置默认的SERD，可用SERD并实现您自己的自定义Serdes的信息，请参见数据类型和序列化。存在的几种变体指定一个自定义流部门，可让您控制输出记录如何在输出主题的分区中分布。