使用jps 命令
[1] 9795
[root@localhost kafka]# jps
10099 Jps
8294 Kafka
9574 NamesrvStartup
[1]+ Done bin/kafka-server-start.sh -daemon config/server.properties
发送接收消息的配置如下
1.appacliation.properties
spring.kafka.bootstrap-servers=192.168.209.128:9092
spring.kafka.consumer.group-id=0
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.batch-size=65536
spring.kafka.producer.buffer-memory=524288
2.java 发送接收消息
@GetMapping("/sendOrder")
public String sendOrder(@RequestParam("orderId")String orderId) {
kafkaTemplate.send("order",new Order(orderId));
return "success";
}
@KafkaListener(topics = {"order"})
public void receiveOrder(ConsumerRecord<?,?>consumer) {
logger.info("{}-{}:{}",consumer.topic(),consumer.key(),consumer.value());
}
刚开始我执行了一个发送string 消息的,结果就是死循环一样不停的打印Exception 之前的消息,
哪位大佬给解决下,多谢。