kafka连接器 发表于 2020-10-09 更新于 2023-10-28 分类于 kafka 阅读次数： Valine： 本文字数： 6.9k 阅读时长 ≈ 6 分钟 连接器kafka自带了对连接器应用的脚本，用于将数据从外部系统导入到kafka或从kafka中导出到外部系统。kafka连接器有独立模式和分布式模式两种工作模式。kafka自带脚本connect-standalone.sh和connect-distributed.sh分别对应kafka连接器的两种工作模式。 阅读全文 »
kafka分区 发表于 2020-10-09 更新于 2023-10-28 分类于 kafka 阅读次数： Valine： 本文字数： 7k 阅读时长 ≈ 6 分钟 分区操作分区Leader平衡当创建一个主题时，该主题的分区及副本会被均匀的分配到kafka集群的相应节点上，这样优先副本也在集群中均匀分布。当一个主题创建后优先副本会作为分区的Leader副本，Leader负责所有的读写操作。 阅读全文 »
kafka配置 发表于 2020-10-09 更新于 2024-06-04 分类于 kafka 阅读次数： Valine： 本文字数： 2.5k 阅读时长 ≈ 2 分钟 配置管理kafka-configs脚本管理配置，支持修改(alter)和查看(describe)配置两个基本操作 阅读全文 »
kafka消费者 发表于 2020-10-09 更新于 2024-06-05 分类于 kafka 阅读次数： Valine： 本文字数： 21k 阅读时长 ≈ 19 分钟 消费者kafka的消费者以pull的方式获取消息，同时采用了消费者组的模式，每个消费者都属于某个消费者组。在创建消费者时，若不指定消费者的groupId，则该消费者属于默认消费者组 阅读全文 »
kafka生产者 发表于 2020-10-09 更新于 2024-03-12 分类于 kafka 阅读次数： Valine： 本文字数： 38k 阅读时长 ≈ 35 分钟 kafka生产者kafka使用脚本kafka-console-producer.sh命令发送消息 阅读全文 »