Worked with from server.properties Uncomment And Replace <HOST IP> with actual IP. ... Read More | Share it now!
Category: Kafka
Kafka tools
List kafka consumer groups: kafka-consumer-groups --bootstrap-server localhost:9092 --list List kafka topics: kafka-topics --zookeeper localhost:2181 --list Add partitions to topics: bin/kafka-topics.sh --zookeeper localhost:2181 --alter --topic... Read More | Share it now!
Kafka跨集群同步工具——MirrorMaker
MirrorMaker是为解决Kafka跨集群同步、创建镜像集群而存在的；下图展示了其工作原理。该工具消费源集群消息然后将数据重新推送到目标集群。 MirrorMaker使用方式 启动mirror-maker程序需要一个或多个consumer配置文件、一个producer配置文件是必须的其他参数是可选的。 kafka-run-class.sh... Read More | Share it now!
Kafka集群数据同步MirrorMaker
修改配置文件 vim $KAFKA_HOME/config/consumer.properties... Read More | Share it now!
kafka partition（分区）与 group
一、 1、原理图 2、原理描述 一个topic... Read More | Share it now!
Why many developer’s end up using both Kafka and RabbitMQ
Bradley McAllister Many companies use the latest and greatest technologies to keep their applications e5cient and fast and to make themselves productive. Today I am going to examine the major features that developers look for in their messaging... Read More | Share it now!
Quickstart kafka installing
This tutorial assumes you are starting fresh and have no existing Kafka or ZooKeeper data. Since Kafka console scripts are different for Unix-based and Windows platforms, on Windows platforms use bin\windows\ instead of bin/, and change the script... Read More | Share it now!
kafka_exporter
https://github.com/danielqsj/kafka_exporter Kafka exporter for Prometheus. For other metrics from Kafka, have a look at the JMX exporter. Table of Contents Compatibility Dependency Download Compile Build Binary Build Docker Image Run Run... Read More | Share it now!
Filebeat中文指南
翻译自：https://www.elastic.co/guide/en/beats/filebeat/current/index.html 下面的博客是公司里使用filebeat的实例，可以直接借鉴，有问题可以向我反馈。 Filebeat... Read More | Share it now!
[转]使用Python操作Kafka
https://blog.csdn.net/see_you_see_me/article/details/78468421 yum -y install python-pip pip install kafka-python from kafka import KafkaProducer producer = KafkaProducer(bootstrap_servers='localhost:9092') Traceback (most recent call last): File... Read More | Share it now!