文章浏览阅读85次。#!/bin/bashkafka_home=/opt/module/kafka-3.2.1#${kafka_home}/bin/kafka-topics.sh --zookeeper hadoop102:2181,hadoop103:2181,hadoop104:2181 --create --replication-factor 2 --partitions 6 --topic $1${k......

文章浏览阅读114次。[alex@hadoop102 ~]$ cd /usr/local/bin/[alex@hadoop102 bin]$ sudo touch kafka-topic-describe.sh[alex@hadoop102 bin]$ sudo chown alex:alex kafka-topic-describe.sh [alex@hadoop102 bin]$ chmod 755 kafk..._topic_describe...

文章浏览阅读663次。[alex@hadoop102 ~]$ cd /usr/local/bin/[alex@hadoop102 bin]$ sudo touch kafka-topic-list.sh[alex@hadoop102 bin]$ sudo chown alex:alex kafka-topic-list.sh [alex@hadoop102 bin]$ chmod 755 kafka-topic-..._topic --list...

文章浏览阅读49次。[alex@hadoop102 ~]$ cd /usr/local/bin/[alex@hadoop102 bin]$ sudo touch kafka-topic-delete.sh[alex@hadoop102 bin]$ sudo chown alex:alex kafka-topic-delete.sh [alex@hadoop102 bin]$ chmod 755 kafka-to..._kafka-topic.sh --delete...

文章浏览阅读150次。文章目录1 什么是kafka2 组件概念2.1 broker2.2 topic2.3 partition2.4 producer2.5 consumer2.6 Consumer Group2.7 offset1 什么是kafkakafka 是一个分布式的,分布订阅模式的消息队列.2 组件概念2.1 brokerkafka的节点,一个kafka节点就是一个b......

文章浏览阅读1.2k次。[alex@hadoop102 ~]$ cd /usr/local/bin/[alex@hadoop102 bin]$ sudo touch kafka-topic-create.sh[alex@hadoop102 bin]$ sudo chown alex:alex kafka-topic-create.sh[alex@hadoop102 bin]$ chmod 755 kafka-top..._kafka-top create...

...

...

...

文章浏览阅读4.3k次。查看topic信息：bin/kafka-topics.sh --list --bootstrap-server common1:9092查看topic内容：bin/kafka-console-consumer.sh --bootstrap-server common1:9092 --topic hbcs_db --from-beginning创建topic:bin/kafka-topics.sh --create --bootstrap-server common1:9092 --topic......