代码之家 › 专栏 › 技术社区 › Thiru

限制每个主题使用的消息

spring-kafka apache-kafka spring-boot

Thiru · 技术社区 · 7 年前

使用者服务的配置方式必须确保例如,30个执行器在主题和5个执行器,用于处理中的每条消息低的主题。

如果执行器被占用并且正在运行当前任务,是否有方法配置使用者停止使用来自相应主题的消息?

1 回复 | 直到 7 年前

Gary Russell 7 年前

你不应该把工作交给任务执行者;它会导致提交偏移量时出现问题。

您应该为每个主题使用不同的侦听器容器,每个容器具有不同的并发设置。

这样容器就可以管理并发性。

推荐文章

Nuñito Calzada · Spring Boot with JWT:访问此资源需要完全身份验证

1 年前

Kallydi · jdbc无法连接到docker中的postgresql数据库

1 年前

PatPanda · 使用springboot验证请求中的列表是否为[null]

1 年前

Dónal · Spring Boot应用程序中的伪造证明文件类型验证

1 年前

Bojidar Kaloyanov · 为什么即使有有效的JWT,Spring Boot也会对安全端点的POST请求返回403 Forbidden?

1 年前

Ariel Vilche · WebSecurityConfiguration bean Spring引导安全中的自动连线错误

1 年前

mikeb · Maven和Spring引导-我需要强制logback 1.5.13,但不能

1 年前

CoderJammer · springdoc openapi生成器模板定制

1 年前

Nuñito Calzada · AWS SDK 1.12.780 Java版的凭据

1 年前

Python_user · build/lib不是由gradle build生成的

1 年前