auto-offset-reset: earliest
发布时间：2025-06-24 19:10:39 作者：北方职教升学中心 阅读量：278
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer。
或者使用application.yml配置文件：。
以下是配置Kafka的基本示例：
application.properties配置文件：。您就可以通过制造商向指定的topic发送消息c;并通过消费者收到这些消息。
auto-offset-reset: earliest。
value-serializer: org.apache.kafka.common.serialization.StringSerializer。
group-id: my-group。
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer。
String message = (String) record.value();
System.out.println("Received message in group 'my-group': " + message);
}。
@Autowired。
bootstrap-servers: localhost:9092。
producer:。
private KafkaTemplate<String, String> kafkaTemplate;
public void sendMessage(String topic, String message) {。
consumer:。
value-deserializer: org.apache.kafka.common.serialization.StringDeserializer。
spring.kafka.bootstrap-servers=localhost:9092。
key-serializer: org.apache.kafka.common.serialization.StringSerializer。
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer。
key-deserializer: org.apache.kafka.common.serialization.StringDeserializer。
确保你的pom.Springgngml包含Spring Kafka依赖
<dependency>
<groupId>org.springframework.kafka</groupId>
<artifactId>spring-kafka</artifactId>
<version>2.8.0</version> <!-- Use the appropriate version -->
</dependency>
接下来，您可以创建生产者和消费者来发送和接收信息：
生产者:。
}。
spring.kafka.consumer.group-id=my-group。
Spring Kafka配置在Boot中c;你需要application.properties或application.Kafka的基本属性，并添加必要的依赖性。
spring:。
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer。
spring.kafka.consumer.auto-offset-reset=earliest。
确保您的Kafka服务器正在运行，而且你的Spring 可以连接到Boot应用程序。
kafka:。这样，
