0%

连接器

kafka自带了对连接器应用的脚本,用于将数据从外部系统导入到kafka或从kafka中导出到外部系统。kafka连接器有独立模式和分布式模式两种工作模式。kafka自带脚本connect-standalone.sh和connect-distributed.sh分别对应kafka连接器的两种工作模式。

阅读全文 »

分区操作

分区Leader平衡

当创建一个主题时,该主题的分区及副本会被均匀的分配到kafka集群的相应节点上,这样优先副本也在集群中均匀分布。当一个主题创建后优先副本会作为分区的Leader副本,Leader负责所有的读写操作。

阅读全文 »

配置管理

kafka-configs脚本管理配置,支持修改(alter)和查看(describe)配置两个基本操作

阅读全文 »

消费者

kafka的消费者以pull的方式获取消息,同时采用了消费者组的模式,每个消费者都属于某个消费者组。在创建消费者时,若不指定消费者的groupId,则该消费者属于默认消费者组

阅读全文 »

kafka生产者

kafka使用脚本kafka-console-producer.sh命令发送消息

阅读全文 »