ogg同步数据到kafka，报错ClassNotFoundException: kafkahandler

最近使用ogg同步数据到kafka，配置文件已经配好，启动目标端的extract时报错： 我的配置文件为： kafka.props文件 custom_kafka_producer.properties…

kafka消费reset offset问题

kafka消费端包如下错误： 2016-07-12 14:02:45,076 [ConsumerFetcherThread-order-consumer-group_iZ25mmzglleZ-1468299172455-8b8f5ebd-0-3] ERROR …

kafka的producer发送消息异常

kafka的producer端，可以正常运行，如下 运行一段时间后，突然异常，异常代码如下 2016-09-05 16:57:54|WARN kafka.utils.Logging$class.warn(Loggin…

在python-flask中调用kafka发送消息，消费者收不到

首先，在没有flask的时候，我写了kafka的程序，一个生产者，一个消费者。 生产者进程，它负责读取本地的一张图片，把图片的二进制数据以消息的形式发…

kafka集成zookeeper，使用最新kafka-client，自动提交，测试异常情况，数据未丢失？

如题和下面consumer代码片段： Properties props = new Properties(); props.put("bootstrap.servers", "192.168.83.20:9092"); props.put("metadata…

kafka分区leader切换

kafka+storm构架 kafka 版本kafka_2.10-0.8.2.1，topic 副本数为2。zk版本3.4.6，storm版本apache-storm-0.9.4 近期storm消费总发现下面这样的报错：…

kafka 新增分区后，部分分区一直无法消费？

使用同一个group.id消费一个topic，原来的topic分区为3,在使用的工程中，新增分区为6，使用的kafkaoffsetmonitor进行监控，，发现有3个分区一直无法…

activemq，kafka，Jafka，怎么选型啊

activemq，kafka，Jafka，怎么选型啊 我要点对点、发布/订阅都支持 实现jms标准的 …

启动kafka失败，这条命令执行不成功呀

启动kafka失败，这条命令执行不成功呀 [root@master kafka]#  JMX_PORT=9997 bin/kafka-server-start.sh config/server-1.properties & …

kafka不支持消息过滤，但项目中需要这个功能，该如何解决？

kafka不支持消息过滤，但项目中需要这个功能，该如何解决？…

有没有人遇到过kafka连接阿里云服务器，却连不上，报了个奇怪的异常

kafka在日志监控平台使用

@卢禹 你好，想跟你请教个问题：我现在有个需求，用logstash抓取日志到kafka以后，同时做实时日志监控，和日志静态分析，实时日志监控用ELK实现，日…

Kafka自动提交偏移量失败。谁没有大神给看看咋回事？

比特币矿池项目，项目的核心就是Kafka，个别模块偶尔会出现自动提交偏移量失败的日志，日志如下： Marking the coordinator 124.160.26.251:9092 (id:…

使用spring-integration-kafka集成spring和kafka，遇到问题

最近在做springboot与kafka的集成： 环境：kafka_2.11-0.8.2.2，spring-integration-kafka：1.3.1，zk：zookeeper-3.4.6 最近一周都在研究kafka，实…

kafka 配置了多个消费者 只有一个消费者收到信息

场景： zookeeper 集群： 3 台服务器 kafka 集群：3 台服务器 broker.id:[0,1,2] num.partitions=2 正常启动没问题 一个生产者 topic 创建语句： sudo…