高端操作：KAFKA ON IPV6实战系列《二》

大数据从业者 2021-06-02

4430

前言

书接上回，说到centos开启并且配置IPV6地址。我们亲爱的客户需要将Kafka以监听IPV6的地址运行，并且对外提供以IPV6地址能生产和消费Kafka数据。PS：我一度怀疑私信给我的朋友就是某些局点的客户。。。

部署Kafka

懒省事了，直接从官网下载个2.7.1版本。不用修改任何配置项。

[root@felixzh bigdata]# wget https://www.apache.org/dyn/closer.cgi?path=/kafka/2.7.1/kafka_2.12-2.7.1.tgz
[root@felixzh bigdata]# tar -zxvf kafka_2.12-2.7.1.tgz
[root@felixzh bigdata]# cd kafka_2.12-2.7.1
[root@felixzh kafka_2.12-2.7.1]# pwd
/home/bigdata/kafka_2.12-2.7.1
[root@felixzh kafka_2.12-2.7.1]# ll
total 40
drwxr-xr-x. 3 root root  4096 May 31 02:25 bin
drwxr-xr-x. 2 root root  4096 Apr  8 07:32 config
drwxr-xr-x. 2 root root  8192 May 31 02:24 libs
-rw-r--r--. 1 root root 14535 Apr  8 07:29 LICENSE
drwxr-xr-x. 2 root root   236 Apr  8 07:32 licenses
-rw-r--r--. 1 root root   953 Apr  8 07:29 NOTICE
drwxr-xr-x. 2 root root    44 Apr  8 07:32 site-docs

先启动zookeeper、再启动kafka。

[root@felixzh kafka_2.12-2.7.1]# bin/zookeeper-server-start.sh config/zookeeper.properties

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-server-start.sh config/server.properties

IPV4地址测试

先创建一个用于测试的topic

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-topics.sh --zookeeper localhost:2181 --create --partitions 1 --replication-factor 1 --topic test

生产数据：地址使用localhost

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

消费数据：地址使用localhost

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

IPV6地址测试

修改kafka参数listeners

listeners=PLAINTEXT://[2010::25]:9092

生产数据：地址使用2010::25

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-console-producer.sh --broker-list [2010::25]:9092 --topic test

消费数据：地址使用2010::25

[root@felixzh kafka_2.12-2.7.1]# bin/kafka-consoconsumer.sh --bootstrap-server [2010::25]:9092 --topic test --from-beginning

至此，KAFKA可以运行在IPV6上！！

大数据

文章转载自大数据从业者，如果涉嫌侵权，请发送邮件至：contact@modb.pro进行举报，并提供相关证据，一经查实，墨天轮将立刻删除相关内容。

高端操作：KAFKA ON IPV6实战系列《二》

评论