要向Kafka发送消息,你需要使用Kafka的生产者API。以下是一个简单的示例代码,展示了如何使用Java向Kafka发送消息:
import org.apache.kafka.clients.producer.Producer;
import org.apache.kafka.clients.producer.ProducerRecord;
import org.apache.kafka.clients.producer.KafkaProducer;
import java.util.Properties;
public class KafkaProducerExample {
public static void main(String[] args) {
// Kafka 服务器的地址和端口
String bootstrapServer = "localhost:9092";
// 消息的主题
String topic = "test-topic";
// 设置生产者的配置属性
Properties props = new Properties();
props.put("bootstrap.servers", bootstrapServer);
props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
// 创建 Kafka 生产者实例
Producer<String, String> producer = new KafkaProducer<>(props);
try {
// 发送一条消息到 Kafka
String message = "Hello, Kafka!";
producer.send(new ProducerRecord<>(topic, message));
System.out.println("消息发送成功: " + message);
} catch (Exception e) {
e.printStackTrace();
} finally {
// 关闭 Kafka 生产者
producer.close();
}
}
}
在上面的示例中,我们首先设置了Kafka服务器地址和端口,以及要发送消息的主题。然后,我们创建了一个包含必要配置属性的Properties
对象。接下来,我们使用这些配置属性创建了一个Kafka生产者实例。最后,我们使用send
方法向Kafka发送一条消息,并在控制台上打印出成功发送的消息。最后,我们关闭了Kafka生产者。
你可以根据自己的需求进行修改和扩展这个示例代码。
辰迅云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
推荐阅读: java中pattern的用法有哪些