kafka中删除topic问题
marked for deletion 网上一片文章说在server.properties里配置delete.topic.enable=true 我没找到这句 就自己添加上去了 但是不起作用 求指教正确…
kafka远程部署完后启动，远程断开kafka也自动断开
求助！！！ 使用kafka和zookeeper搭建集群，zookeeper已经搭建OK，kafka配置参数也已经完成，所有的过程都是远程连接服务器部署安装。部署完成后zook…
spring-integration-kafka2.1配置异常找不到listener-container
在配置消费者的时候出现的异常如下，找不到container1这个参数配置，在spring-integration-kafka.xsd找了发现listener-container指向的是org.springfr…
tomcat启动，运行kafka-consumer端代码报错
启动tomcat，访问kafka-Consumer端代码（注意是从tomcat启动访问startJob（）方法） public void startJob() throws Exception{ Properties …
kafka_2.10-0.10.0.0版本发送消息问题
@卢禹 你好，想跟你请教个问题：我将kafka升级到最新版本，使用内置的zookeeper，broker配置只修改了zoookeeper.connect=10.1.114.72：2181 ，listen…
kafka消费数据，一段时间后无法消费，需要重换groupId
将图片数据base64以后，写入kafka，然后用java 写了一个消费代码，开始跑，没有问题，可以消费到数据，并处理，但是最近发现，跑一段时间无法消费到数…
kafka 在putty 中启动 为何关闭putty 服务就停止了
命令： 末尾有& 照常理是后台运行啊 /opt/kafka/bin/kafka-server-start.sh /opt/kafka/config/server.properties & …
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test运行失败
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test [2016-08-22 01:06:00,875] WARN Property topic is not valid (kafka.ut…
如何让kafka消费者处于等待消费状态而不是直接退出？
使用spring-boot spirng-kafka, 建了2个项目， 一个producer,一个consumer, 测试的时候使用producer向kafka发送几条消息， 然后启动consumer能够成功…
