请帮我写出一个简单的kafka使用案例
时间: 2024-05-13 08:13:46 浏览: 7
好的,以下是一个简单的使用 Kafka 的案例:
1. 首先,在你的项目中引入 Kafka 的依赖。
2. 创建一个 Kafka 生产者并连接到 Kafka 集群:
```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<String, String> producer = new KafkaProducer<>(props);
```
3. 创建一个 Kafka 消费者并连接到 Kafka 集群:
```java
Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
props.put("group.id", "test-group");
props.put("key.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
props.put("value.deserializer", "org.apache.kafka.common.serialization.StringDeserializer");
Consumer<String, String> consumer = new KafkaConsumer<>(props);
```
4. 发送消息到 Kafka 集群:
```java
ProducerRecord<String, String> record = new ProducerRecord<>("test-topic", "key", "value");
producer.send(record);
```
5. 从 Kafka 集群中消费消息:
```java
consumer.subscribe(Collections.singletonList("test-topic"));
while (true) {
ConsumerRecords<String, String> records = consumer.poll(Duration.ofSeconds(1));
for (ConsumerRecord<String, String> record : records) {
System.out.printf("offset = %d, key = %s, value = %s%n", record.offset(), record.key(), record.value());
}
}
```
希望这个简单的案例能够帮助到你。如果你有任何其它问题,请随时问我。