将三个系统的kafka发送失败的数据收集起来，至于存到哪里还没定论，不过怎么把失败的数据收集起来啊
1条回答 默认 最新
- 2022-02-16 11:32回答 4 已采纳 重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
- 2021-04-20 02:49回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
- 2022-09-26 09:35回答 1 已采纳 网上都有相关文章，例如，你可以参考这篇：https://www.bilibili.com/read/cv11773508里面就有涉及到这两个的安全认证配置。
- 2024-09-05 13:25qq_33192454的博客 } } } 把这些代码改成一个独立的应用服务有自己的端口通过post请求传递json报文，然后给kafka发送消息 要将 Kafka 生产者代码改成一个独立的应用服务，能够通过 POST 请求接收 JSON 报文并将其发送到 Kafka，你可以...
- 2022-01-28 01:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2022-05-06 04:49回答 2 已采纳 问题解决方式：新建一个异常处理器，将异常名放到@KafkaListener注解的errorHandler属性里面，当监听抛出异常时，会进入到异常处理器中。 @Bean public C
- 2021-07-22 00:54回答 4 已采纳 用@Scheduledhttps://blog.csdn.net/limingcai168/article/details/103394041
- 2022-12-13 05:30吕炎霖的日常的博客 kafka发送和接收数据。
- 2020-04-28 06:06回答 1 已采纳 kafka消费是可以指定offset的，你手动指定一个不就好了？ 多个生产者同时发送数据，你是要保证按照发送的顺序一一写到数据库中么？这样子的话可以只给当前topic，设置一个分区就行了 不知道我
- 2022-03-23 03:28回答 1 已采纳 要保证集群中每一台机器的broker.id是唯一的也就是server.properties配置文件中找到broker.id，如果不存在的话就自己添加一行，配置方式是broker.id = 0broke
- 2022-07-13 12:33回答 3 已采纳 restclient异常，先看看taskmanager和jobmanager是否正常，然后你可以在jobmanager的节点上访问webUI查看job状态，又或者直接查看宿主机上的日志排查问题
- 2021-03-13 17:11weixin_39912566的博客 } }/*** 发送缓存数据到kafka，发送成功，删除缓存数据，失败过10分钟重试 * *@parampath 保存缓存数据的[目录]*/ private static voidsendToKafka(String path) { String message; KafkaProducerWrapper sender= ...
- 2021-03-14 03:21地理沙龙的博客 我在远程机器上设置了kafka和zookeeper . 在那台机器上我可以看到下面在官方网站上使用测试方法 .> bin/kafka-console-producer.sh --broker-list localhost:9092 --topic listings-incomingThis is a ...
- 2021-10-27 12:14九师兄的博客 一个网友迷糊了，问题如下自己自定义一个callback呀，然后把消息传递进去，这样你异常的时候 就可以用了。
- 2023-05-12 05:55乐得屁颠儿。的博客 Java kafka发送接收
- 没有解决我的问题, 去提问
问题事件
系统已结题
8月11日
已采纳回答
8月4日-
创建了问题
7月27日
- 京ICP备19004658号
- 经营性网站备案信息
公安备案号11010502030143- 营业执照
- 北京互联网违法和不良信息举报中心
- 家长监护
- 中国互联网举报中心
- 网络110报警服务
- Chrome商店下载
- 账号管理规范
- 版权与免责声明
- 版权申诉
- 出版物许可证
- ©1999-2025北京创新乐知网络技术有限公司
