我有这样的kstream拓扑结构：
KStream<String, Data> eventStream = streamsBuilder.stream("event",
Consumed.with(Serdes.String(), eventSerde);
KTable<String, Result> resultKTable = streamsBuilder.table("result",
Consumed.with(Serdes.String(), resultSerde));
eventStream.leftJoin(resultKTable, new Joiner())
.to("result", Produced.with(Serdes.String(), resultSerde));当我在“事件”主题中发送tombstone记录时，出现此错误
Skipping record due to null join key or value. key=[3428642] value=[null] topic=[event] partition=[0] offset=[21]
1条答案
按热度按时间9lowa7mx1#
这不是错误，而是警告。
如Kafka Streams文档中针对KStream-KTable左连接所写：
具有空键或空值的流的输入记录将被忽略，并且不会触发连接
这是预期情景。
边注：luppeng.wordpress.com上有一篇关于这个问题和可能的解决方案的博客，可能会派上用场。