求教kafka ACL问题
请教下各位朋友， 目前碰上的问题1， zkServer.sh start 后zkCli.sh 进入客户端 然后添加用户 addauth digest user1:password1 设置权限 setAcl /test…
rabbitmq怎么实现类似kafka的comsumerGroup机制
rabbitmq怎么实现类似kafka的comsumerGroup机制需求是这样的消息中间件使用的是kafka现在需要在用户支付成功以后做几个操作给供应商发通知，给客户发…
什么情况下kafka消费者组的状态会为dead？如何避免？
问题描述：本地用kakfa0.9的客户端消费，消费者组配置到代码里，每一个消费者组有一个消费者。刚启动消费，代码消费没有问题。过两天突然不消费了，…
spring boot 集成kafka 打包 失败
问题描述 spring boot 集成Java 在打包的时候 出现 could not be established. Broker may not be available 如何跳过 这个步骤 相关代码 配置如下 s…
Kafka的consumer如何根据offset来确定读取哪个patition呢？
刚接触kafka研究其原理，了解到在同一个partition内部消息是保证有序的 但是我用一个consumer去读多个partition的topic的时候，利用的只是一个offset…
- 共 1 页
- 1
