kafka在--spring.cloud.bootstrap.name=bootstrap-dev方式启动下取不到监听数据
3条回答 默认 最新
- 2021-04-20 10:49回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
- 2022-02-16 19:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2021-07-27 10:36回答 1 已采纳 kafka调用send方法发送数据后 会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
- 2021-03-09 19:59bgwsoye的博客 importorg.apache.kafka.clients.consumer.ConsumerRebalanceListener;importorg.apache.kafka.clients.consumer.KafkaConsumer;importorg.apache.kafka.clients.consumer.OffsetAndMetadata;importorg.apache.kafka...
- 2022-08-23 10:01回答 1 已采纳 同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
- 2021-07-22 08:54回答 4 已采纳 用@Scheduledhttps://blog.csdn.net/limingcai168/article/details/103394041
- 2022-12-21 00:45回答 1 已采纳 这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
- 2021-08-14 21:01大亨•博的博客 Kafka中不自动消费的问题解决方案 查看源码 如果项目中有多个不同的topic需要消费，那么一定要注意@KafkaListener中id的配置，源码中如下 /** * The unique identifier of the container managing for this ...
- 2023-02-02 16:54回答 4 已采纳 ''该回答引用ChatGPT''如对你的问题有帮助，请点击右侧采纳即可！没有使用ZooKeeper的话，一种可行的方案是利用ClickHouse的复制功能实现双机数据同步。ClickHouse的复制功
- 2022-07-13 20:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2021-04-19 17:13回答 2 已采纳 连接问题 检查下ip和端口
- 2021-04-10 15:33幻想青年卢六六的博客 最近在做平台的kafka消息监听的改造，以前用的是平台自己封装jar，现在统一改用spring-kafka.jar,这样的好处是减少特殊处理，便于统一维护。以下是配置：import java.util.*;/*** @Description: kafka配置类* @...
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2020-07-20 14:460k绝对零度的博客 @KafkaListener 所在类添加注解 @Component
- 2022-12-13 13:30吕炎霖的日常的博客 kafka发送和接收数据。
- 没有解决我的问题, 去提问
悬赏问题
- ¥20 arcgis制做交通拥堵时变图
- ¥15 AD20 PCB板步线 这个要怎么步啊
- ¥50 关于《奇迹世界》1.5版本，数据修改
- ¥15 请问这个问题如何解决(关键词-File)
- ¥50 visual studio 2022和EasyX图形化界面
- ¥15 找一下报错原因，纠正一下
- ¥50 Cox回归模型Nomogram图制作报错
- ¥20 SQL如何查询多级用户的数据
- ¥15 给车牌识别代码加一个识别轮廓长宽比的代码
- ¥30 商品价格预测的transformer模型优化