apache-kafka - java.lang.IllegalStateException：这不应该发生为 timestamp()

Question

我们使用处理器 API 在我们的应用程序中使用 Kafka 流。当我们在主题流中有数据时，有时会失败并出现以下错误。

“这不应该发生，因为 timestamp() 应该只在处理记录时调用 java.lang.IllegalStateException：这不应该发生，因为 timestamp() 应该只在处理记录时调用”

我已经浏览了与此相关的文档，但是如何每次都创建新的处理器实例？而且我们不会添加新处理器，它是我们应用程序中唯一的一个处理器。你能帮我们解决这个问题吗

https://docs.confluent.io/platform/current/streams/faq.html#why-do-i-get-an-illegalstateexception-when-accessing-record-metadata

拓扑代码：在拓扑中创建一个新实例

  topology.addProcessor(ServiceConstants.EVENT_PROCESSOR, () -> new ObjectProcessor(helper),
                ServiceConstants.EVENTS);

标签： apache-kafkaapache-kafka-streams