跑步
ccloud kafka topic consume <topic> -b --print-key
以错误结束: panic: runtime error: index out of range [0] with length 0
我想知道的是,这是否是可能发生的事情,或者我在看这个主题中的某种损坏的数据?
我之所以问这个问题,是因为我在使用某个主题的某个服务中遇到了一个空指针异常,我不太清楚为什么会发生这种情况,因为即使是在tombstone记录的情况下,我也会预料到这种情况 key
将不为空,但 value
可以为空(如果是墓碑记录,则为空)。所以在过滤掉 null
在价值上我不知道还能做什么?
[编辑]:当我用同样的方法 confluent-kafka-python
然后我没有得到任何错误,但是我在这个过程中得到了一些空记录。现在看来,代码中的错误,当从一个主题读取时,是通过过滤掉空值来解决的。 .filter((key, value) -> key != null || value != null)
我会想 null
键被跳过?
[编辑2]已连接到我的另一个但相关的问题,此处未描述。我不知道 .toStream()
在加入另一个之后 KTable
会把链子往下推一个墓碑记录。
暂无答案!
目前还没有任何答案,快来回答吧!