然而,KStream不断地向Kafka发送Delete请求。[DENY] Auth request Delete on Topic:app-TopicName-repartition by User test_user (cached) (io.aiven.kafka.auth.AivenAclAuthorizer删除请求仅用于重新分区主题,而不是其他中间主题。这个应用程序运行得非常好。它一直发送后台删除请求,因为我已经将retries设置为Integer.MAX_VA
我们使用了带有函数的Kafka流。我们有一个典型的示例应用程序,它将用户单击的kstream与用户区域ktable连接起来。我们知道,在定义拓扑时,可以使用接受物化存储名称的appropiate方法来强制内部changelog或重新分区主题的自定义名称: public BiFunction<KStreamsecondClicks, Materialized.as("bifunctionktable-reduce"))