Kafka生产者在CentOS如何配置

?CentOS???Kafka?????????,????????????Kafka???????????????????????:

1. ??Java??

Kafka??Java??,??????????Java???????????OpenJDK 8:

sudo yum install java-1.8.0-openjdk-devel

??Java??:

java -version

2. ?????Kafka

?Apache Kafka?????????Kafka,??????????????:

wget https://downloads.apache.org/kafka/3.5.2/kafka_2.12-3.5.2.tgz
tar -xzf kafka_2.12-3.5.2.tgz
cd kafka_2.12-3.5.2

3. ??Kafka

??server.properties??

?Kafka?config?????server.properties??,???????:

• broker.id: ??Kafka broker?ID???????
• listeners: ?????????
• security.inter.broker.protocol: ??SASL_PLAINTEXT???
• sasl.enabled.mechanisms: ??PLAIN?????
• log.dirs: Kafka????????
• zookeeper.connect: Zookeeper????

????:

broker.id=0
listeners=SASL_PLAINTEXT://your_server_ip:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN
sasl.mechanism.inter.broker.protocol=PLAIN
log.dirs=/tmp/kafka-logs
zookeeper.connect=localhost:2181

?????

????Kafka?????(???9092):

sudo firewall-cmd --zone=public --add-port=9092/tcp --permanent
sudo firewall-cmd --reload

4. ??Kafka??

?Kafka?bin???,????????Kafka???:

./kafka-server-start.sh config/server.properties

5. ??Topic

????????????Topic:

./kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

6. ??Kafka???

Kafka?????????????,?????bootstrap.servers?????????,?Java???:

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

Producer producer = new KafkaProducer<>(props);

7. ?????

???????????:

./kafka-console-producer.sh --broker-list localhost:9092 --topic test

??????????,???Kafka??????????????????

????

• ?????:Linux???Kafka??????????
• ?Centos???,??Kafka??
• CentOS7????Kafka3.2.0(?SpringBoot????)
• 01 CentOS7???kafka?????????
• centos???kafka??????supervisor??
• centos7??kafka?????
• ??CentOS??Kafka
• Centos7 kafka?????

?????????????CentOS???Kafka???????????,???????????????