To send a message to Kafka in Java, you can use the KafkaProducer class from the Kafka Clients library. Here is an example code snippet:

import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class KafkaProducerExample {

    public static void main(String[] args) {

        // set up the producer properties
        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");

        // create a KafkaProducer instance
        Producer<String, String> producer = new KafkaProducer<>(props);

        // create a message to send
        String topic = "my-topic";
        String key = "my-key";
        String value = "Hello, Kafka!";

        // create a ProducerRecord instance with the topic, key, and value
        ProducerRecord<String, String> record = new ProducerRecord<>(topic, key, value);

        // send the message
        producer.send(record);

        // close the producer
        producer.close();
    }
}

In this example, we first set up the producer properties, including the Kafka broker address, key and value serializers. Then, we create a KafkaProducer instance with these properties. Next, we create a message to send, consisting of a topic, key, and value. We use these to create a ProducerRecord instance. Finally, we call the send() method on the producer instance to send the message, and close the producer

In java code show me how send message to kafka give me an example

原文地址: http://www.cveoy.top/t/topic/doBd 著作权归作者所有。请勿转载和采集!

免费AI点我,无需注册和登录