如何测试kafka发送和接收消息（启动两个终端）

在Apache Kafka中，你可以分别在生产者和消费者端启动两个终端来进行消息的发送和接收测试。这里是一个基本流程：

**在生产者终端**:
1. **启动生产者**:
使用之前配置好的`KafkaProducer`启动，发送消息到指定主题。例如：

   java -jar kafka-producer-*.jar --topic your-topic

这里假设你有一个名为`kafka-producer.jar`的应用，包含生产者的逻辑。

2. **发送消息**:
发送一些预设的消息，例如`"Hello World!"`。记得指定主题名和分区（如果需要的话）。

**在消费者终端**:
1. **启动消费者**:
同样使用官方库`KafkaConsumer`，指定主题名称启动监听：

   java -jar kafka-consumer-*.jar --bootstrap-server localhost:9092 --topic your-topic

2. **验证接收到的消息**:
消费者会自动拉取并显示接收到的消息。检查终端输出，看看是否能看到生产者发送的消息。

注意：为了保证测试，生产者和消费者的`bootstrap.servers`配置应该匹配，并且生产者需要先发送消息，然后消费者才能接收到。