SpringBoot整合Kafka（3）_spring-kafka3 kafkatemplate

1. send发送消息

1. sendDefault发送消息

1.1 创建defaultKafkaTemplate

    //kafkaTemplate实现了Kafka发送接收等功能
    @Bean
    @Primary
    public KafkaTemplate<Integer, String> kafkaTemplate() {
   
        KafkaTemplate template = new KafkaTemplate<Integer, String>(producerFactory());
        return template;
    }

    @Bean("defaultKafkaTemplate")
    public KafkaTemplate<Integer, String> defaultKafkaTemplate() {
   
        KafkaTemplate template = new KafkaTemplate<Integer, String>(producerFactory());
        template.setDefaultTopic("topic.quick.default");
        r
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

1.2 消息生产者producer

package zhw.example.zhw.kafka;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.annotation.Resource;

@Controller
@RequestMapping(value = "kafka")
public class producer {
   

    @Resource
    private KafkaTemplate defaultKafkaTemplate;

    @ResponseBody
    @RequestMapping(value = 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17