windows kafka 生产者
时间: 2023-11-13 20:58:50 浏览: 85
您可以使用 Kafka 的 Java 客户端来创建一个生产者。以下是一个简单的示例代码:
```java
import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerRecord;
import java.util.Properties;
public class KafkaProducerExample {
public static void main(String[] args) {
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");
KafkaProducer<String, String> producer = new KafkaProducer<>(props);
String topic = "my-topic";
String message = "Hello, Kafka!";
ProducerRecord<String, String> record = new ProducerRecord<>(topic, message);
producer.send(record);
producer.close();
}
}
```
在上面的代码中,我们首先创建了一个 `Properties` 对象,用于配置 Kafka 生产者。然后,我们创建了一个 `KafkaProducer` 对象,并指定了要发送消息的主题和消息内容。最后,我们使用 `producer.send(record)` 方法将消息发送到 Kafka 集群。
阅读全文