KafkaTemplate生产者回调

超、凢脫俗 2022-09-07 12:22 50阅读 0赞

例子如下：

@Autowired
        KafkaTemplate<String, String> kafkaTemplate;
    
        public void testKafkaTemplate () {
            ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("topic", "{\"key\": \"value\"}");
    
            CompletableFuture<SendResult<String, String>> completable = future.completable();
            completable.whenCompleteAsync((n, e) -> {
                if (null != e) {
                    System.out.println("发送报错了");
                } else {
                    System.out.println("发送成功了！");
                }
            });
        }
    
        public void testKafkaTemplate1() {
            ListenableFuture<SendResult<String, String>> future = kafkaTemplate.send("topic", "{\"key\": \"value\"}");
            future.addCallback(new ListenableFutureCallback<SendResult<String, String>>() {
                @Override
                public void onFailure(Throwable throwable) {
                    //
                }
    
                @Override
                public void onSuccess(SendResult<String, String> stringStringSendResult) {
                    //
                }
            });
        }

发表评论取消回复

表情：

评论列表（有 0 条评论，50人围观）

还没有评论，来说两句吧...

相关阅读

相关 Java回调函数异步回调案例

1、回调函数分类回调函数区分：同步回调和异步回调同步回调：意义只在于完成方法调用；异步调用：可实现并发，主业务线程可以及时释放；异步线程完成工作，执行回调函数，

心已赠人/ 2023年07月21日 05:27/ 0 赞/ 89 阅读

相关回调函数：同步回调和异步回调

<!DOCTYPE html> <html lang="en"> <head> <meta charset="UTF-8">

谁借莪１个温暖的怀抱￠/ 2023年06月18日 08:52/ 0 赞/ 123 阅读

相关 kafka生产者回调的使用

> 前言：今天看到有人说kafka生产者在发送消息后，如果发生异常，异常捕获方法里拿不到消息的数据，我想了想，感觉不太对劲，所以验证了一下。首先说下结论：kafka是不会在

梦里梦外;/ 2023年06月17日 04:51/ 0 赞/ 28 阅读

相关 KafkaTemplate生产者回调

例子如下： @Autowired KafkaTemplate<String, String> kafkaTemplate;

超、凢脫俗/ 2022年09月07日 12:22/ 0 赞/ 51 阅读

相关回调函数

回调函数是一种函数指针的使用方式。 stdcall和cdecl的区别：这个问题涉及到函数调用的汇编知识，暂只需记住stdcall和cdecl的参数压栈顺序是相同的，参

傷城~/ 2022年06月12日 07:21/ 0 赞/ 386 阅读

相关回调地狱

回调地狱，就是函数作为参数层层嵌套试想一下，有3个异步请求，第二个以及第三个需要用到前面请求成功的数据，我们会想着，层层嵌套函数来进行处理，例如 ![在这里插入图片描

柔光的暖阳◎/ 2022年03月02日 15:48/ 0 赞/ 386 阅读

相关异步回调发展（地狱回调）

最近在看koa的代码基本上前几句就会写道async于是想写下关于链式操作的发展第一次普通Js回调时代，所有的异步操作都会写道cb function de

曾经终败给现在/ 2022年01月20日 00:27/ 0 赞/ 487 阅读

相关 Java回调机制CallBack总结(生产者消费者模式、监听者模式)

什么是回调在A类中定义了一个方法，这个方法中用到了一个接口和该接口中的抽象方法，但是抽象方法没有具体的实现，需要B类去实现，B类实现该方法后，它本身不会去调用该方法，而

谁践踏了优雅/ 2021年11月01日 12:26/ 0 赞/ 505 阅读

相关异步回调

异步回调 2019-08-14 目录 1 回调 2 使用wait和notify方法实现异步回调 3 使用CountDownLatch实现异步回调 1

雨点打透心脏的1/2处/ 2021年10月23日 16:34/ 0 赞/ 509 阅读

相关回调与回调函数

回调与回调函数回调回调函数回调回调指的是某函数在执行的时候，由于某些原因，该函数被迫中止执行，交出当前线程的使用权，当前线程转而执行其它函

悠悠/ 2021年09月25日 04:26/ 0 赞/ 659 阅读