kafka无法消费消息的问题
如题，kafka出现严重的消息堆积，求大伙帮忙分析一下原因，下面对问题做一些描述： 1. 我是用java写的代码，部署在tomcat 2. 另一个应用也是…
kafka Consumer kafka_2.9.1-0.8.2.2 java消费kafka 报错求解
[2015-12-04 06:00:04,713] INFO 0 successfully elected as leader (kafka.server.ZookeeperLeaderElector) [2015-12-04 06:00:05,107] INFO Got us…
kafka配置了多个消费者，只有一个消费者收到信息
我想一个生产者对应多个消费者 多个消费者轮询消费 group.id不一样到时候就所正常到，2个消费者同时收到 当我把group.id设置成一样的时候，只有一个…
kafka java客户端kafka-clients 0.8.2.1
首先maven依赖如下： <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version&…
kafka-server-start.sh server.properties kafka执行启动失败，怎么解决
FATAL  (kafka.Kafka$) java.io.FileNotFoundException: server.properties at kafka.Kafka.main(Kafka.scala) [root@master bin]# kafka-server-…
启动kafka报错，应该怎么解决
root上执行这条命令不成功：kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test root@maste…
spark streaming on yarn每个批次接收的数据量非常少的问题
最近在调试spark on yarn的程序,通过spark streming调用kafka的低阶API实时获取kafka中的数据,spark streaming中每个批次获取到的kafka数据非常少,只…
