{"id":221,"date":"2023-05-25T05:55:22","date_gmt":"2023-05-24T21:55:22","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/index.php\/uncategorized\/ea06fdc815\/"},"modified":"2023-05-25T21:22:58","modified_gmt":"2023-05-25T13:22:58","slug":"ea06fdc815","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/spring-boot\/ea06fdc815\/","title":{"rendered":"\u4e00\u8d77\u6765\u5b66kafka\u4e4b\u6574\u5408SpringBoot\u57fa\u672c\u4f7f\u7528"},"content":{"rendered":"
\n

<\/span>\u4e00\u8d77\u6765\u5b66kafka\u4e4b\u6574\u5408SpringBoot\u57fa\u672c\u4f7f\u7528<\/span><\/h1>\n

<\/span>\u524d\u8a00<\/span><\/h2>\n

\u76ee\u524d\u6b63\u5728\u51fa\u4e00\u4e2aKafka\u4e13\u9898<\/code>\u7cfb\u5217\u6559\u7a0b, \u7bc7\u5e45\u4f1a\u8f83\u591a, \u559c\u6b22\u7684\u8bdd\uff0c\u7ed9\u4e2a\u5173\u6ce8\u2764\ufe0f ~<\/p>\n

\u672c\u8282\u7ed9\u5927\u5bb6\u8bb2\u4e00\u4e0bKafka\u5982\u4f55\u6574\u5408SpringBoot<\/code>\u4ee5\u53ca\u5b83\u7684\u57fa\u672c\u4f7f\u7528~<\/p>\n

<\/mp-common-profile><\/section>\n

\u597d\u4e86, \u5e9f\u8bdd\u4e0d\u591a\u8bf4\u76f4\u63a5\u5f00\u6574\u5427~<\/p>\n

<\/span>\u9879\u76ee\u642d\u5efa<\/span><\/h2>\n

\u540c\u6837\u7684\uff0c\u9700\u8981\u6211\u4eec\u642d\u5efa\u4e00\u4e2amaven<\/code>\u5de5\u7a0b\uff0c\u6574\u5408\u975e\u5e38\u7684\u7b80\u5355\uff0c\u9700\u8981\u7528\u5230:<\/p>\n

<\/span><dependency<\/span>><\/span>
    <groupId<\/span>><\/span>org.springframework.kafka<\/groupId<\/span>><\/span>
    <artifactId<\/span>><\/span>spring-kafka<\/artifactId<\/span>><\/span>
<\/dependency<\/span>><\/span>
<\/code><\/pre>\n
\u6765\u4e00\u8d77\u770b\u4e0b\u5b8c\u6574\u7684pom.xml<\/code>:<\/p>\n
<\/span><?xml version=\"1.0\" encoding=\"UTF-8\"?><\/span>
<project<\/span> xmlns<\/span>=\"http:\/\/maven.apache.org\/POM\/4.0.0\"<\/span>
         xmlns:xsi<\/span>=\"http:\/\/www.w3.org\/2001\/XMLSchema-instance\"<\/span>
         xsi:schemaLocation<\/span>=\"http:\/\/maven.apache.org\/POM\/4.0.0 http:\/\/maven.apache.org\/xsd\/maven-4.0.0.xsd\"<\/span>><\/span>
    <modelVersion<\/span>><\/span>4.0.0<\/modelVersion<\/span>><\/span>

    <groupId<\/span>><\/span>org.example<\/groupId<\/span>><\/span>
    <artifactId<\/span>><\/span>springboot-kafka-all<\/artifactId<\/span>><\/span>
    <version<\/span>><\/span>1.0-SNAPSHOT<\/version<\/span>><\/span>

    <properties<\/span>><\/span>
        <java.version<\/span>><\/span>1.8<\/java.version<\/span>><\/span>
    <\/properties<\/span>><\/span>

    <parent<\/span>><\/span>
        <groupId<\/span>><\/span>org.springframework.boot<\/groupId<\/span>><\/span>
        <artifactId<\/span>><\/span>spring-boot-starter-parent<\/artifactId<\/span>><\/span>
        <version<\/span>><\/span>2.1.3.RELEASE<\/version<\/span>><\/span>
    <\/parent<\/span>><\/span>

    <dependencies<\/span>><\/span>
        <!--web--><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>org.springframework.boot<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>spring-boot-starter-web<\/artifactId<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <!--test--><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>org.springframework.boot<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>spring-boot-starter-test<\/artifactId<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <!-- kafka--><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>org.springframework.kafka<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>spring-kafka<\/artifactId<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <!--Hutool\u4f9d\u8d56--><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>cn.hutool<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>hutool-all<\/artifactId<\/span>><\/span>
            <version<\/span>><\/span>5.8.4<\/version<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <!--fast-json--><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>com.alibaba<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>fastjson<\/artifactId<\/span>><\/span>
            <version<\/span>><\/span>1.2.58<\/version<\/span>><\/span>
        <\/dependency<\/span>><\/span>

        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span> org.slf4j <\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span> slf4j-api <\/artifactId<\/span>><\/span>
            <version<\/span>><\/span> 1.6.4 <\/version<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>org.slf4j<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>slf4j-simple<\/artifactId<\/span>><\/span>
            <version<\/span>><\/span>1.7.25<\/version<\/span>><\/span>
            <scope<\/span>><\/span>compile<\/scope<\/span>><\/span>
        <\/dependency<\/span>><\/span>
        <dependency<\/span>><\/span>
            <groupId<\/span>><\/span>org.projectlombok<\/groupId<\/span>><\/span>
            <artifactId<\/span>><\/span>lombok<\/artifactId<\/span>><\/span>
        <\/dependency<\/span>><\/span>
    <\/dependencies<\/span>><\/span>

    <build<\/span>><\/span>
        <plugins<\/span>><\/span>
            <plugin<\/span>><\/span>
                <groupId<\/span>><\/span>org.springframework.boot<\/groupId<\/span>><\/span>
                <artifactId<\/span>><\/span>spring-boot-maven-plugin<\/artifactId<\/span>><\/span>
                <version<\/span>><\/span>2.1.3.RELEASE<\/version<\/span>><\/span>
            <\/plugin<\/span>><\/span>
        <\/plugins<\/span>><\/span>
    <\/build<\/span>><\/span>

<\/project<\/span>><\/span>
<\/code><\/pre>\n
\u914d\u7f6e\u4e5f\u5f88\u7b80\u5355 application.yml<\/code><\/p>\n
<\/span>server:<\/span>
  port:<\/span> 8081<\/span>

spring:<\/span>
  kafka:<\/span>
    producer:<\/span>
      bootstrap-servers:<\/span> 127.0<\/span>.0<\/span>.1<\/span>:9092<\/span>
<\/code><\/pre>\n
\u7136\u540e\u65b0\u5efa\u4e00\u4e2a\u542f\u52a8\u7c7b\uff0c\u770b\u4e0b\u63a7\u5236\u53f0\u662f\u5426\u6210\u529f\u94fe\u63a5\u4e86Kafka<\/code>,\u5728\u542f\u52a8\u4e4b\u524d\u522b\u5fd8\u4e86\u5f00\u542f\u6211\u4eec\u7684Kafka\u96c6\u7fa4<\/code>\u54e6~<\/p>\n
<\/span>\u57fa\u672c\u4f7f\u7528<\/span><\/h2>\n
\u5148\u4ece\u4e00\u4e2a\u7b80\u5355\u7684\u4f8b\u5b50\uff0c\u6765\u5feb\u901f\u4f53\u9a8c\u4e00\u4e0bKafka<\/code>,\u65b0\u5efaHelloController<\/code><\/p>\n
<\/span>@Slf<\/span>4j
@RestController<\/span>
public<\/span> class<\/span> HelloController<\/span> <\/span>{

    private<\/span> static<\/span> final<\/span> String topic = \"test\"<\/span>;

    @Autowired<\/span>
    private<\/span> KafkaTemplate<Object, Object> kafkaTemplate;

    \/\/ \u63a5\u6536\u6d88\u606f<\/span>
    @KafkaListener<\/span>(id = \"helloGroup\"<\/span>, topics = topic)
    public<\/span> void<\/span> listen<\/span>(String msg)<\/span> <\/span>{
        log.info(\"hello receive value: {}\"<\/span> , msg);
        \/\/ hello receive value: hello kafka<\/span>
    }

    @GetMapping<\/span>(\"\/hello\"<\/span>)
    public<\/span> String hello<\/span>()<\/span> <\/span>{
        \/\/ \u53d1\u9001\u6d88\u606f<\/span>
        kafkaTemplate.send(topic, \"hello kafka\"<\/span>);
        return<\/span> \"hello\"<\/span>;
    }
}

<\/code><\/pre>\n
\u6211\u4eec\u901a\u8fc7KafkaTemplate<\/code>\u8fdb\u884c\u6d88\u606f\u7684\u53d1\u9001, \u901a\u8fc7@KafkaListener<\/code>\u8fdb\u884c\u6d88\u606f\u7684\u6d88\u8d39,\u6211\u4eec\u53ef\u4ee5\u6307\u5b9a\u6d88\u8d39\u8005ID<\/code>\u4ee5\u53ca\u76d1\u542c\u7684topic<\/code>\uff0c\u8bf7\u6c42localhost:8081\/hello<\/code>\u89c2\u5bdf\u63a7\u5236\u53f0\u7684\u53d8\u5316\u3002\u8bf7\u6c42\u540e\uff0c\u53d1\u73b0\u6d88\u606f\u53d1\u9001\u548c\u63a5\u6536\u7684\u975e\u5e38\u5feb,\u6211\u4eec\u4e5f\u53ef\u4ee5\u89c2\u5bdfUI<\/code>\u540e\u53f0\u7684\u6d88\u606f\u8be6\u60c5,\u540c\u6b65\u5bf9\u6bd4<\/p>\n
<\/span>topic\u521b\u5efa<\/span><\/span><\/h3>\n
\u4e4b\u524d\u6211\u4eec\u7684topic<\/code>\u662f\u5728UI<\/code>\u540e\u53f0\u521b\u5efa\u7684\uff0c\u90a3\u4e48\u5728SpringBoot<\/code>\u4e2d\u5982\u4f55\u521b\u5efa\u5462? \u4e0b\u9762\u6211\u4eec\u8bd5\u7740\u53d1\u9001\u4e00\u4e2a\u4e0d\u5b58\u5728\u7684topic<\/code><\/p>\n
<\/span> \/\/ \u5f53topic\u4e0d\u5b58\u5728\u65f6 \u4f1a\u9ed8\u8ba4\u521b\u5efa\u4e00\u4e2atopic<\/span>
    \/\/ num.partitions = 1 #\u9ed8\u8ba4Topic\u5206\u533a\u6570<\/span>
    \/\/ num.replica.fetchers = 1 #\u9ed8\u8ba4\u526f\u672c\u6570<\/span>
    @GetMapping<\/span>(\"\/hello1\"<\/span>)
    public<\/span> String hello1<\/span>()<\/span> <\/span>{
        \/\/ \u53d1\u9001\u6d88\u606f<\/span>
        kafkaTemplate.send(\"hello1\"<\/span>, \"hello1\"<\/span>);
        return<\/span> \"hello1\"<\/span>;
    }

    \/\/ \u63a5\u6536\u6d88\u606f<\/span>
    @KafkaListener<\/span>(id = \"hello1Group\"<\/span>, topics = \"hello1\"<\/span>)
    public<\/span> void<\/span> listen1<\/span>(String msg)<\/span> <\/span>{
        log.info(\"hello1 receive value: {}\"<\/span> , msg);
        \/\/ hello1 receive value: hello1<\/span>
    }
<\/code><\/pre>\n
\u8bf7\u6c42\u4e4b\u540e\uff0c\u89c2\u5bdf\u63a7\u5236\u53f0\u4ee5\u53ca\u7ba1\u7406\u540e\u53f0\uff0c\u53d1\u73b0\u5e76\u6ca1\u6709\u62a5\u9519\uff0c\u5e76\u4e14\u7ed9\u6211\u4eec\u81ea\u52a8\u521b\u5efa\u4e86\u4e00\u4e2atopic<\/code>,\u5728\u81ea\u52a8\u521b\u5efa\u4e0b\uff0c\u9ed8\u8ba4\u7684\u53c2\u6570\u662f\uff1a<\/p>\n
<\/span>  num.partitions = 1 #\u9ed8\u8ba4Topic\u5206\u533a\u6570
  num.replica.fetchers = 1 #\u9ed8\u8ba4\u526f\u672c\u6570
<\/code><\/pre>\n
\u5982\u679c\u6211\u60f3\u624b\u52a8\u521b\u5efa\u5462?\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7NewTopic<\/code>\u6765\u624b\u52a8\u521b\u5efa:<\/p>\n
<\/span>@Configuration<\/span>
public<\/span> class<\/span> KafkaConfig<\/span> <\/span>{
    @Bean<\/span>
    public<\/span> KafkaAdmin admin<\/span>(KafkaProperties properties)<\/span><\/span>{
        KafkaAdmin admin = new<\/span> KafkaAdmin(properties.buildAdminProperties());
        \/\/ \u9ed8\u8ba4False,\u5728Broker\u4e0d\u53ef\u7528\u65f6,\u5982\u679c\u4f60\u89c9\u5f97Broker\u4e0d\u53ef\u7528\u5f71\u54cd\u6b63\u5e38\u4e1a\u52a1\u9700\u8981\u663e\u793a\u7684\u5c06\u8fd9\u4e2a\u503c\u8bbe\u7f6e\u4e3aTrue<\/span>
        admin.setFatalIfBrokerNotAvailable(true<\/span>);
        \/\/ setAutoCreate(false) : \u9ed8\u8ba4\u503c\u4e3aTrue\uff0c\u4e5f\u5c31\u662fKafka\u5b9e\u4f8b\u5316\u540e\u4f1a\u81ea\u52a8\u521b\u5efa\u5df2\u7ecf\u5b9e\u4f8b\u5316\u7684NewTopic\u5bf9\u8c61<\/span>
        \/\/ initialize()\uff1a\u5f53setAutoCreate\u4e3afalse\u65f6\uff0c\u9700\u8981\u6211\u4eec\u7a0b\u5e8f\u663e\u793a\u7684\u8c03\u7528admin\u7684initialize()\u65b9\u6cd5\u6765\u521d\u59cb\u5316NewTopic\u5bf9\u8c61<\/span>
        return<\/span> admin;
    }

    \/**
     * \u521b\u5efa\u6307\u5b9a\u53c2\u6570\u7684 topic
     * @return<\/span>
     *\/<\/span>
    @Bean<\/span>
    public<\/span> NewTopic topic<\/span>()<\/span> <\/span>{
        return<\/span> new<\/span> NewTopic(\"hello2\"<\/span>, 0<\/span>, (short<\/span>) 0<\/span>);
    }
}
<\/code><\/pre>\n
\u5982\u679c\u8981\u66f4\u65b0\u5462?\u4e5f\u975e\u5e38\u7684\u7b80\u5355<\/p>\n
<\/span> \/**
     * \u66f4\u65b0 topic
     * @return<\/span>
     *\/<\/span>
    @Bean<\/span>
    public<\/span> NewTopic topicUpdate<\/span>()<\/span> <\/span>{
        return<\/span> new<\/span> NewTopic(\"hello2\"<\/span>, 1<\/span>, (short<\/span>) 1<\/span>);
    }
<\/code><\/pre>\n
\u6ce8\u610f\u8fd9\u91cc\u7684\u53c2\u6570\u53ea\u80fd+<\/code>\u4e0d\u80fd-<\/code><\/p>\n
\u90a3\u4e48\u53c8\u6709\u5c0f\u4f19\u4f34\u95ee\u4e86\uff0c\u8fd9\u79cd\u65b9\u5f0f\u592a\u7b80\u5355\u4e86\uff0c\u5982\u679c\u6211\u60f3\u5728\u4ee3\u7801\u903b\u8f91\u4e2d\u6765\u521b\u5efa\u5462?\u6211\u4eec\u53ef\u4ee5\u901a\u8fc7AdminClient<\/code>\u6765\u624b\u52a8\u521b\u5efa<\/p>\n
<\/span>  \/**
     * AdminClient \u521b\u5efa
     *\/<\/span>
    @Autowired<\/span>
    private<\/span> KafkaProperties properties;

    @GetMapping<\/span>(\"\/create\/{topicName}\"<\/span>)
    public<\/span> String createTopic<\/span>(@PathVariable String topicName)<\/span> <\/span>{
        AdminClient client = AdminClient.create(properties.buildAdminProperties());
        if<\/span>(client !=null<\/span>){
            try<\/span> {
                Collection<NewTopic> newTopics = new<\/span> ArrayList<>(1<\/span>);
                newTopics.add(new<\/span> NewTopic(topicName,1<\/span>,(short<\/span>) 1<\/span>));
                client.createTopics(newTopics);
            }catch<\/span> (Throwable e){
                e.printStackTrace();
            }finally<\/span> {
                client.close();
            }
        }
        return<\/span> topicName;
    }
<\/code><\/pre>\n
\u89c2\u5bdf\u4e0b\u7ba1\u7406\u540e\u53f0\uff0c\u53d1\u73b0topic<\/code>\u90fd\u521b\u5efa\u6210\u529f\u4e86~<\/p>\n
<\/span>\u83b7\u53d6\u6d88\u606f\u53d1\u9001\u7684\u7ed3\u679c<\/span><\/h2>\n
\u6709\u65f6\u5019\u6211\u4eec\u53d1\u9001\u6d88\u606f\u4e0d\u77e5\u9053\u662f\u4e0d\u662f\u53d1\u6210\u529f\u4e86\uff0c\u9700\u8981\u6709\u4e00\u4e2a\u7ed3\u679c\u901a\u77e5\u3002\u6709\u4e24\u79cd\u65b9\u5f0f\uff0c\u4e00\u79cd\u662f\u540c\u6b65<\/code>\u4e00\u79cd\u662f\u5f02\u6b65<\/code><\/p>\n
<\/span>\u540c\u6b65\u83b7\u53d6\u7ed3\u679c<\/span><\/span><\/h3>\n
<\/span>\/**
     * \u83b7\u53d6\u901a\u77e5\u7ed3\u679c
     * @return<\/span>
     *\/<\/span>
    @GetMapping<\/span>(\"\/hello2\"<\/span>)
    public<\/span> String hello2<\/span>()<\/span> <\/span>{
        \/\/ \u540c\u6b65\u83b7\u53d6\u7ed3\u679c<\/span>
        ListenableFuture<SendResult<Object,Object>> future = kafkaTemplate.send(\"hello2\"<\/span>,\"hello2\"<\/span>);
        try<\/span> {
            SendResult<Object,Object> result = future.get();
            log.info(\"success >>> {}\"<\/span>, result.getRecordMetadata().topic()); \/\/ success >>> hello2<\/span>
        }catch<\/span> (Throwable e){
            e.printStackTrace();
        }

        return<\/span> \"hello2\"<\/span>;
    }
<\/code><\/pre>\n
<\/span>\u5f02\u6b65\u83b7\u53d6<\/span><\/span><\/h3>\n
<\/span>\/**
     * \u83b7\u53d6\u901a\u77e5\u7ed3\u679c
     * @return<\/span>
     *\/<\/span>
    @GetMapping<\/span>(\"\/hello2\"<\/span>)
    public<\/span> String hello2<\/span>()<\/span> <\/span>{
        \/\/ \u53d1\u9001\u6d88\u606f - \u5f02\u6b65\u83b7\u53d6\u901a\u77e5\u7ed3\u679c<\/span>
        kafkaTemplate.send(\"hello2\"<\/span>, \"async hello2\"<\/span>).addCallback(new<\/span> ListenableFutureCallback<SendResult<Object, Object>>() {
            @Override<\/span>
            public<\/span> void<\/span> onFailure<\/span>(Throwable throwable)<\/span> <\/span>{
                log.error(\"fail >>>>{}\"<\/span>, throwable.getMessage());
            }

            @Override<\/span>
            public<\/span> void<\/span> onSuccess<\/span>(SendResult<Object, Object> objectObjectSendResult)<\/span> <\/span>{
                log.info(\"async success >>> {}\"<\/span>, objectObjectSendResult.getRecordMetadata().topic()); \/\/ async success >>> hello2<\/span>
            }
        });

        return<\/span> \"hello2\"<\/span>;
    }
<\/code><\/pre>\n
<\/span>Kafka\u4e8b\u52a1<\/span><\/h2>\n
\u540c\u6837\u7684,\u6d88\u606f\u4e5f\u4f1a\u5b58\u5728\u4e8b\u52a1<\/code>,\u5982\u679c\u7b2c\u4e00\u6761\u6d88\u606f\u53d1\u9001\u6210\u529f\uff0c\u518d\u53d1\u7b2c\u4e8c\u6761\u6d88\u606f\u7684\u65f6\u5019\u51fa\u73b0\u5f02\u5e38\uff0c\u90a3\u4e48\u5c31\u4f1a\u629b\u51fa\u5f02\u5e38\u5e76\u56de\u6eda\u7b2c\u4e00\u6761\u6d88\u606f,\u4e0b\u9762\u901a\u8fc7\u4e00\u4e2a\u7b80\u5355\u7684\u4f8b\u5b50\u4f53\u4f1a\u4e00\u4e0b<\/p>\n
<\/span>@GetMapping<\/span>(\"\/hello3\"<\/span>)
public<\/span> String hello3<\/span>()<\/span> <\/span>{
    kafkaTemplate.executeInTransaction(t -> {
        t.send(\"hello3\"<\/span>,\"msg1\"<\/span>);
        if<\/span>(true<\/span>)
            throw<\/span> new<\/span> RuntimeException(\"failed\"<\/span>);
        t.send(\"hello3\"<\/span>,\"msg2\"<\/span>);
        return<\/span> true<\/span>;
    });

    return<\/span> \"hello3\"<\/span>;
}

\/\/ \u63a5\u6536\u6d88\u606f<\/span>
@KafkaListener<\/span>(id = \"hello3Group\"<\/span>, topics = \"hello3\"<\/span>)
public<\/span> void<\/span> listen3<\/span>(String msg)<\/span> <\/span>{
    log.info(\"hello3 receive value: {}\"<\/span> , msg);
}
<\/code><\/pre>\n
\u9ed8\u8ba4\u60c5\u51b5\u4e0b\uff0cSpring-kafka<\/code>\u81ea\u52a8\u751f\u6210\u7684KafkaTemplate<\/code>\u5b9e\u4f8b\uff0c\u662f\u4e0d\u5177\u6709\u4e8b\u52a1\u6d88\u606f\u53d1\u9001\u80fd\u529b\u7684\u3002\u6211\u4eec\u9700\u8981\u6dfb\u52a0transaction-id-prefix<\/code>\u6765\u6fc0\u6d3b\u5b83<\/p>\n
<\/span>spring:<\/span>
  kafka:<\/span>
    producer:<\/span>
      bootstrap-servers:<\/span> 127.0<\/span>.0<\/span>.1<\/span>:9092<\/span>
      transaction-id-prefix:<\/span> kafka_.<\/span>
<\/code><\/pre>\n
\u542f\u52a8\u4e4b\u540e\uff0c\u89c2\u5bdf\u63a7\u5236\u53f0\u7684\u53d8\u5316~ \uff0c\u9664\u6b64\u4e4b\u5916\uff0c\u8fd8\u53ef\u4ee5\u4f7f\u7528\u6ce8\u89e3\u7684\u65b9\u5f0f@Transactional<\/code>\u6765\u5f00\u542f\u4e8b\u52a1<\/p>\n
<\/span>\/\/ \u6ce8\u89e3\u65b9\u5f0f<\/span>
    @Transactional<\/span>(rollbackFor = RuntimeException.class<\/span>)
    @GetMapping<\/span>(\"\/hello4<\/span>\")
    public<\/span> String<\/span> hello4<\/span>() <\/span>{
        kafkaTemplate.send(\"hello3\"<\/span>,\"msg1\"<\/span>);
        if<\/span>(true<\/span>)
            throw<\/span> new<\/span> RuntimeException(\"failed\"<\/span>);
        kafkaTemplate.send(\"hello3\"<\/span>,\"msg2\"<\/span>);
        return<\/span> \"hello4\"<\/span>;
    }
<\/code><\/pre>\n
<\/span>\u7ed3\u675f\u8bed<\/span><\/h2>\n
\u4e0b\u8282\u5e26\u5927\u5bb6\u770b\u4e0bSpringBoot\u6574\u5408Kafka<\/code>\u6df1\u5165\u4f7f\u7528~<\/p>\n
<\/mp-common-miniprogram><\/section>\n
\u300c\u672c\u7740\u628a\u81ea\u5df1\u77e5\u9053\u7684\u90fd\u544a\u8bc9\u5927\u5bb6\uff0c\u5982\u679c\u672c\u6587\u5bf9\u60a8\u6709\u6240\u5e2e\u52a9\uff0c\u70b9\u8d5e+\u5173\u6ce8<\/code>\u9f13\u52b1\u4e00\u4e0b\u5457~\u300d<\/strong><\/p>\n
<\/span>\u76f8\u5173\u6587\u7ae0<\/span><\/h2>\n