【已连接kafka成功】Kafka生产者初始化

Properties producerProps = new Properties();
        producerProps.put("bootstrap.servers", "你的集群地址");
        producerProps.put("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"用户名\"password=\"密码\";");
        producerProps.put("security.protocol", "SASL_PLAINTEXT");
        producerProps.put("sasl.mechanism", "SCRAM-SHA-512");
        producerProps.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        producerProps.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        Producer producer = new org.apache.kafka.clients.producer.KafkaProducer(producerProps);
        producer.send(new ProducerRecord<>("自己的topic主题名称","msg要发送的信息"));
1
2
3
4
5
6
7
8
9

以上kafka生产者在使用SASL_PLAINTEXT的情况下，也就是需要使用用户名和密码来连接kafka；若kafka不需要用户名和密码即可连接，则取消相关配置设置即可。