我正在用spring开发一个消费者应用程序。我计划用吊舱保持24*7的运行速度。但是,最近我知道有一些批处理过程会在中间运行。而且,当这些批处理正在运行时,我们的处理不应该发生。因此,也许,我必须停止对记录的轮询,当批处理完成后,我可以继续进行处理。但是,我不知道如何实现这一点..。
无论批处理是否正在运行,我可以通过查看一些标志来查询并从表中获取详细信息。但是,我如何才能停止对记录的投票呢?如果我只是让消费者应用程序在没有处理任何东西的情况下运行,那么它不会引起再平衡吗?
Config类:
@Bean
public ConsumerFactory<String, Gen
我是从mqtt到骆驼消费,并试图发表到融合卡夫卡,但当我生产卡夫卡,我得到以下错误
java.lang.IllegalArgumentException: Login module control flag is not available in the JAAS config
at org.apache.kafka.common.security.JaasConfig.loginModuleControlFlag(JaasConfig.java:85) ~[kafka-clients-3.1.1.jar:na]
at org.apache.kafka.common.secur