在我们的 Kafka Streams 拓扑中,我们有一些标点,可能需要很长时间才能运行(几分钟)。
如此缓慢的标点符号有什么后果?它们运行的进程会在 punctuate 运行时停止处理记录吗?它们会导致重新平衡吗?
apache-kafka apache-kafka-streams
apache-kafka ×1
apache-kafka-streams ×1