我的Kafka消费者必须倾听多个主题。每个主题都定义了一个优先级，比如说-高、低和中。使用者服务的配置方式必须确保，例如，它有30个执行器用于处理高主题中的消息，5个执行器用于处理低主题和中主题中的每条消息。如果执行器被占用并且正在运行当前任务，是否有方法配置使用者停止使用来自相应主题的消息？
e3bfsja21#
你不应该把工作交给任务执行者；它会导致提交偏移量时出现问题。您应该为每个主题使用不同的侦听器容器，每个容器具有不同的并发设置。这样容器就可以管理并发性。
1条答案
按热度按时间e3bfsja21#
你不应该把工作交给任务执行者；它会导致提交偏移量时出现问题。
您应该为每个主题使用不同的侦听器容器，每个容器具有不同的并发设置。
这样容器就可以管理并发性。