kafka自定义producer链接topic错误

kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.
[2017-10-25 22:02:15,757] ERROR Failed to send requests for topics xutongtp with correlation ids in 0,12
at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:98)
at kafka.producer.Producer.send(Producer.scala:78)
at kafka.javaapi.producer.Producer.send(Producer.scala:35)
at kafka.transwarp.io.KafkaProducer.produce(KafkaProducer.java:34)
at kafka.transwarp.io.KafkaMain.main(KafkaMain.java:7)

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

1条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
Young-Eric 2017-10-27 09:23
关注
你检查检查，Topic正确吗？

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

pycharm中kafka错误问题 kafka python ubuntu 有问必答
2021-06-17 17:19

回答 10 已采纳 https://blog.csdn.net/qq_40407889/article/details/118028472 java的kafka操作的简单demo
Kafka bin目录下执行./kafka-console-producer.sh失败 java 有问必答
2021-03-29 16:19

回答 4 已采纳不是说文件权限，你是不是开启了 kafka 的认证，也就是说你要推送消息的话，需要认证。具体情况，你就要去百度看看怎么关闭了。
编写一个生产者程序mysql_producer.py: json kafka
2022-05-22 16:56

回答 1 已采纳库没安装好吧第一句引入就报错了尝试卸载重装试下安装文档： Install — kafka-python 2.0.2-dev documentation
kafka自定义producer从mysql获取数据存储至kafka
2021-05-23 15:47

博学天下的博客 package test; /** ...import kafka.javaapi.producer.Producer; import kafka.producer.KeyedMessage; import kafka.producer.ProducerConfig; import kafka.serializer.StringEncoder; import ut.
kafka拉取不到数据 java kafka 分布式有问必答
2022-02-16 19:32

回答 4 已采纳重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
zookeeper 设置 Acl 后 kafka 启动失败 kafka zookeeper 分布式
2022-09-26 17:35

回答 1 已采纳网上都有相关文章，例如，你可以参考这篇：https://www.bilibili.com/read/cv11773508里面就有涉及到这两个的安全认证配置。
Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
2022-10-25 09:26

回答 5 已采纳感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
Flink Sink Kafka 自定义Topic与自定义分区
2020-07-03 10:28

znmdwzy的博客 Flink Sink Kafka 自定义Topic与自定义分区需求背景： Flink处理完成数据后，需要将消息传给Kafka，为了避免数据倾斜，根据消息的主键进行Hash取模，自定义输出到对应的Topic，为了提升从Kafka读取消息的速度，将...
在新建和删除kafka的topic时出现问题 kafka 大数据
2016-04-20 06:28

回答 2 已采纳 http://blog.csdn.net/xiaoyu_bd/article/details/52268647 这里有彻底删除topic的两种方法
在win10启动kafka报错 kafka zookeeper
2022-05-15 21:27

回答 1 已采纳删除异常的主题“movie_real_topic”试试.\bin\kafka-topics --delete --topic movie_real_topic --zookeeper localhos
kafka无法正常启动 kafka
2022-11-14 16:38

回答 2 已采纳帮你找了个相似的问题, 你可以看下: https://ask.csdn.net/questions/7763153这篇博客你也可以参考下：搭建kafka环境遇到kafka闪退问题以及解决办法这篇博客也
Kafka Producer 自定义 拦截器 & 序列化
2022-12-21 22:22

u013433591的博客 kafka 自定义拦截器、自定义序列化
kafka集成flume flume kafka
2023-03-03 20:36

回答 1 已采纳 “Devil组”引证GPT后的撰写：可能有多种原因导致消费者没有消费到所有追加的内容。以下是一些可能的原因：日志追加速度太快，消费者无法跟上。如果日志追加速度非常快，而消费者无法及时消费所有消息，那
Kafka：Producer自定义Partition负载均衡
2022-02-13 09:27

ITKaven的博客 } } Producer自定义Partition负载均衡需要实现org.apache.kafka.clients.producer.Partitioner接口。 package com.kaven.kafka.producer; import org.apache.kafka.clients.producer.Partitioner; import org....
FlinkKafkaProducer默认和自定义分区策略
2022-06-02 22:00

长臂人猿的博客我们经常关注的是Kafka消费者的消费策略，但是又会在某些特殊情况下要求自定义生产者的分区策略：如按序消费：将所有数据写入一个分区中。又或者默认的策略满足我们的业务需求。值得一提的是，FlinkKafkaProducer...
没有解决我的问题, 去提问

悬赏问题

¥35 平滑拟合曲线该如何生成
¥100 c语言，请帮蒟蒻写一个题的范例作参考
¥15 名为“Product”的列已属于此 DataTable
¥15 安卓adb backup备份应用数据失败
¥15 eclipse运行项目时遇到的问题
¥15 关于#c##的问题：最近需要用CAT工具Trados进行一些开发
¥15 南大pa1 小游戏没有界面，并且报了如下错误，尝试过换显卡驱动，但是好像不行
¥15 自己瞎改改，结果现在又运行不了了
¥15 链式存储应该如何解决
¥15 没有证书，nginx怎么反向代理到只能接受https的公网网站