这是我在这里发表的第一篇文章,我不确定以前是否在这里讨论过这个问题,但这里是这样的:我有一个使用处理器API的KafkaStreams应用程序,遵循以下拓扑结构: 1.Produce its process status to an output topic (processor.addSink()) 然而,为了可追溯性的目的,我需要在日志中记录kstreams向输出</
我正在开发一个Kafka流应用程序,它将读取来自输入Kafka主题的消息,并过滤不必要的数据并将其推送到输出Kafka主题。应用程序开始的时候,我得到的是异常。: Not authorized to access group: QC-NormalizedEventProcessor-v1.0.0
我们的Kafka团队对"group.id
A -> A' --> [S]但是我不能这样做,因为当我创建拓扑时,会抛出一个异常:
Caused by: org.apache.kafka.streams.errors.TopologyException但是,如果我在会话控制之后在转换器中这样做,这些转换后的会话可以更改并发送到下游--但它们不会在S中反映它们的新状态--因此对存储的进