2022-04-13
Flume可以正常连接kafka但是发送消息失败
10M安装了zookeeper、flume、kafka，在使用 flume 向 kafka 发送数据功能时，发现 flume 发送数据到 fafka 失败了
我来答
添加附件
收藏
分享
问题补充
1条回答
默认
最新
评论
回答交流
Markdown
请输入正文
提交
相关推荐
执行 Kafka Topic 删除操作报错KAFKA-30001
回答 1
已采纳
可能原因1、客户端命令连接zookeeper地址错误2、Kafka服务异常Kafka部分节点处于停止状态3、Kafka服务端配置禁止删除4、Kafka配置自动创建，且Producer未停止
kafka过来的topic类似a-a a-b a-c 这个格式,如何能不用一个个加入到logstash.conf 就能进行分类筛选?
回答 1
不会路过
无法从Kafka中获取指定topic 消息
回答 1
已采纳
没有日志不好判断具体原因，可能原因如下1、Kafka服务异常2、Consumer中Zookeeper相关连接地址配置错误，导致无法消费3、Consumer发生ConsumerRebalanceFail
从postgresql 到kafka的实时逻辑同步，有哪些比较稳定的工具吗？
回答 2
开源方案Debezium可以了解一下。可以稳定运行在生产环境。
新安装集群启动 Kafka 失败显示认证失败
回答 4
已采纳
先断开对Kafka的认证。等待5分钟，就会被解锁。
多个平台MySQL数据库到单套kafka集群通过canal做同步，这个架构怎么搭建比较好?
回答 3
已采纳
kafka至少三节点的集群，硬盘要速度快，容量大，kafka里java相关的参数肯定要调整。另外最好考虑增量模式，全量模式可能会浪费磁盘空间。
kafka无法正常关闭
回答 1
已采纳
顺序搞反了，先关闭kafka，再关闭zookeeper试试
大佬们 说说Kafka 有啥使用场景了 对这个东西定位不好啊
回答 1
当消息队列使用较为多，可以用作应用解耦。异步处理。消峰填谷。但是一般业务量不大的话，直接读写数据库更加好。否则进他是一个步骤，出他又是一个步骤。然后再写库。中间也有消耗。
执行Kafka Topic 删除操作删除
回答 1
已采纳
可能是Broker目录存储的数据太多，然后导致加载时间过长。server.log日志还有详细点的吗
OGG同步ERROR:OGG-01163
回答 6
oggbug很多的，这种只能初始化
