ccloud cli-index超出范围[0],长度为0

gg0vcinb  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(235)

跑步

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 会把链子往下推一个墓碑记录。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题