"千锋-kafka21学习笔记与实践教程"

千锋-kafka21是一个使用Java编写的Kafka客户端库。使用它可以轻松地在Java应用程序中集成Kafka消息队列功能。为了开始使用千锋-kafka21，首先需要在项目的pom.xml文件中添加以下依赖： ```xml <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>2.4.1</version> </dependency> ``` 接下来，你可以创建一个生产者类，例如MyProducer，用于向Kafka的特定主题发送消息。在这个类中，你需要指定Kafka服务器的地址和主题的名称。以下是一个简单的MyProducer类的示例： ```java public class MyProducer { private final static String TOPIC_NAME = "my-replicated-topic"; public static void main(String[] args) throws ExecutionException, InterruptedException { Properties props = new Properties(); props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "10.31.167.10:9092,10.31.167.11:9092"); // 其他配置... Producer<String, String> producer = new KafkaProducer<>(props); for (int i = 0; i < 100; i++) { ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC_NAME, Integer.toString(i), "value" + i); producer.send(record).get(); } producer.close(); } } ``` 在上面的示例中，我们创建了一个生产者实例，并向名为“my-replicated-topic”的主题发送了100条消息。在发送每条消息之后，我们调用了`producer.close()`方法来关闭生产者实例。 总之，使用千锋-kafka21库，你可以方便地在Java应用程序中集成Kafka消息队列功能，从而实现高效的分布式消息传递和处理。希望上面的示例能够帮助你快速上手使用千锋-kafka21。