Kafka查看topic、consumer group状态命令

Kafka查看topic、consumer group状态命令

原文链接:https://www.cnblogs.com/AcAc-t/p/kafka_topic_consumer_group_command.html 最近工作中遇到需要使用kafka的场景,测试消费程序启动后,要莫名的过几十秒...
kafka消费失败多次重试

kafka消费失败多次重试

Thread consumerThread = new Thread(new Runnable() { public void run() { MessageAndMetadata<byte[], byte[]> messageAndMetadata = null; try...
Kafka消息阻塞

Kafka消息阻塞

转自:http://jis117.iteye.com/blog/2279519 hi all:         大家都很关心kafka消息阻塞的情况(感谢RoctetMQ给我们的教训)。Kafka上线也有一段时间了,确实有出...
kafka一键启动脚本配置

kafka一键启动脚本配置

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/chn_itcast/article/details/78847947 创建onekey目录 mkdir /...
使用Java代码实现实时消费kafka的消息

使用Java代码实现实时消费kafka的消息

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/liuygvip/article/details/78431909 首先maven构建开发项目,配置pom.x...
Kafka的高级消费者与低级消费者

Kafka的高级消费者与低级消费者

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/u012050154/article/details/78580880           在Kafka实战章节,我...
kafka版本不一致导致的一个小问题(二)

kafka版本不一致导致的一个小问题(二)

背景介绍: 我们公司的实时流项目现在用的spark streaming比较多,这里在介绍下版本: spark streaming2.1.0 kafka 0.9.0.0 spark streaming如果想要集成kafka使...
kafka监控工具-kafka_manager

kafka监控工具-kafka_manager

一、kafka_manager介绍 kafka_manager是雅虎公司的一款开源的监控工具。这个管理工具可以很容易地发现分布在集群中的哪些topic分布不均匀,或者是分...
kafka的组件介绍

kafka的组件介绍

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/qq_41455420/article/details/79372051 kafka的组件介绍 Topi...