跑步
ccloud kafka topic consume <topic> -b --print-key
以错误结束：panic: runtime error: index out of range [0] with length 0
我想知道这是否会发生，或者我是否正在查看本主题中的某种损坏数据？
为什么我问这个，是因为我在使用主题的服务之一中收到空指针异常，我不确定为什么会发生这种情况，因为我希望即使在墓碑记录的情况下key也不会为空，但value可以是null（如果墓碑记录为 null）。因此，在过滤掉null有价值的消息后，我不确定还能做什么？
[编辑]：当我用confluent-kafka-python图书馆尝试同样的事情时，我没有收到任何错误，但我确实在这个过程中得到了一些空记录。现在看来，当从主题中读取时，代码中的错误是通过过滤掉空值来解决的。
.filter((key, value) -> key != null || value != null)
我会认为null键被跳过？
[编辑 2] 连接到我的其他但相关的问题，此处未描述。我不知道.toStream()在与另一个人加入后KTable会推动一条墓碑记录。