spring-boot整合kafka一直报错 Unknown error fetching data for topic-partition TPC_NOTICE_FINISH-2
spring.kafka.consumer.bootstrap-servers=10.20.53.90:8092 spring.kafka.consumer.group-id=GRP_TO_SH spring.kafka.consumer.enable-auto-commit=t…
需要给kafka,xxl-job,rabbitmq单独出一个服务吗？
最近再纠结要不要给kafka单独出一个服务A，其它服务调用服务A然后服务A和kafka连接。xxl-job,rabbitmq同理。 如果需要单独出一个服务，这样做的好处和…
kafka可视化工具为啥要连接zookeeper
最近工程需要做一个kafka的可视化工具，(类似于mysql的navicat一样)。查阅了相关资料，包括kafka Tool、kafka monitor等，发现这些工具都是先连接zook…
oracle goldengate+kafka分区问题
ogg到kafka数据同步的时候涉及分区问题，我不想使用ogg+kafka默认的分区规则，想自己实现这分区规则，要自己实现就必须完成黄色框部分的自定义，本人…
Missing required configuration "offset.storage.file.filename" ??这整个啥子好勒?
.kafka.common.config.ConfigException: Missing required configuration "offset.storage.file.filename" which has no default value. at o…
bin/kafka-server-start.sh config/server.properties 启动报错了,,
bin/kafka-server-start.sh config/server.properties bin/kafka-server-start.sh config/server.properties [2021-03-24 13:54:06,793] INFO Re…
kafka连接zookeeper超时。zookeeper是自己搭建的！！但是无限报超时的错误。
下面是主节点和从节点的zookeeper状态： 但是 kafka报错： 这是什么情况， brokerid 和myid 两个都没有错。防火墙也关了 ，服务器时间都是统一的。真…
kafka(版本 0.10)已消费过的数据重复消费，而且是3天前的，zk的log未发现异常
kafka(版本 0.10)已消费过的数据重复消费，而且是3天前的，zk的log未发现异常 三台机器分布式消费，下面是消费端配置 props.put("auto.commi…
kafka集群启动后，每隔10分钟就跳出一条日志，很影响操作
kafka集群启动后，每隔10分钟就跳出一条日志，很影响操作，求教如何关闭日志打印 [2019-03-19 12:56:48,635] INFO [Group Metadata Manager on Broker…
在原kafka集群动态增加分区后，发现刚增加的分区和原分区数据量差距太大？
现在遇到了一个kafka集群分区扩容问题，详细情况为： 我现在kafka 集群为5台机器，现在的主题中分区数为8个，但是没有添加新的机器，只是想将现在的分…
希望有大佬帮我讲解下kafka里的分区，备份，消费者读取数据，希望通俗点谢谢
比如kafka配置的是两个分区，三个备份，一个主题，broker个数为三，那么我以下说的对吗？三个备份的话，每个broker下都有一个主题，同时主题里都有两…
Kafka 与 k8s/docker， 应用是共享还是独占？？
想问下大家部署的kafka集群是共享集群，还是独占集群。 是一个应用，部署一套Kafka集群+k8s。 还是共享一个Kafka集群，上面通过不同的topics来区分应…
flink 并发读取kafka数据问题
各位，小弟请教个问题： 你好，想跟你请教个问题： 各位好：刚开始学习flink,有个问题请教： 我搭建了有5个节点的flink集群（standalone 模式），启…
