kafka pattion数据堆积，然后自动丢失
入上图所示，我开了两个消费者，三个pattion，刚开始是正常的，但是每次大概在跑了一天左右以后，pattion1 中的数据，开始不被消费，出现堆积，通过日…
kafka集群突然挂掉，求救大神看看什么问题出在哪？？
kafka集群，版本是0.8.2.0：hetserver1,hetserver,hetserver3三台主机 hetserver1在17号 21:39开始报错 2020-03-17 21:39:00,040 ERROR kafka.network…
kafka发送消息的时候报超时，有人遇到过吗？
kafka发送消息的时候报超时，有人遇到过吗？ 生产者用的是这个例子：http://orchome.com/6 Exception in thread "main" org.I0Itec.zkclient.excepti…
spring集成kafka消费者监听没有触发是怎么回事？
能运行程序，也能连到服务器上，但是消费者监听没有触发，不知道什么原因 我的kafka消费者文件配置，基础连接的配置属性那部分应该没问题，因为是可以…
同一个group，有两个消费者。为什么处理消息的时候只有一个消费者在消费消息。
一个topic，3个partitions.一个group，2个consumer。实际接受消息，只有一个consumer在消费消息。…
spark streaming中报kafka的offset错误，如何解决
java.lang.AssertionError: assertion failed: Beginning offset 19309438 is after the ending offset 19270980 for topic mc_event_topic partition…
kafka_2.11-1.0.0在控制台kafka-console-consumer消费者消费的时候zookeeper 和 bootstrap-server区别
今天试了两个kafka的版本都存在这个问题 1、创建一个topic kafka-topics.bat --create --partitions 1 --replication-factor 1 --topic test --zookee…
kafka-manager 异常问题
请求页面显示：Yikes! Ask timed out on [ActorSelection[Anchor(akka://kafka-manager-system/), Path(/user/kafka-manager)]] after [5000 ms]…
kafka源码搭建创建主题报错找不到主类kafka.admin.TopicCommand
kafka源码搭建启动成功。 但是创建主题时报错，找不到主类。 kafka-topics.bat --create --zookeeper localhost:2181 --topic test --replication-fac…
KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
ssl.key.password = null     ssl.keymanager.algorithm = SunX509     ssl.keystore.location = null     ssl.…
win10下如何使用docker安装ZooKeeper、Flink、Kafka?
win10下如何使用docker安装ZooKeeper、Flink、Kafka? 各位前辈能给出一些win10安装ZooKeeper、Flink、Kafka的教程吗？…
