A:首先回答第一个问题。如果传输失败,卡夫卡有自己的一套机制,是我们的代码无法控制的。它会自动重发,我们只能控制失败后的重试次数。重发失败的机制是什么?以及后两个问题,我们将在下一节详细介绍:带回调函数的异步发送演示。其实卡夫卡的制作人的信息发送过程如上图所示。它在内部维护一套失败重试机制。可以看出,具体的消息失败重试是由kafka自动完成的,我们只能控制失败重试的次数。
A:其实卡夫卡的制作人的消息发送过程如上图所示。它在内部维护一套失败重试机制。可以看出,具体的消息失败重试是由kafka自动完成的,我们只能控制失败重试的次数。当生产者收到ack时,回调函数将被异步调用。此方法有两个参数,即RecordMetadata和Exception。如果异常为空,则消息发送成功;如果异常不为空,则消息发送不成功。其中一个支持回调函数,当生产者收到ack时会异步调用。此方法有两个参数,即RecordMetadata和Exception。如果异常为空,则消息发送成功;如果异常不为空,则消息发送不成功。
答案:nb spnb sp什么是卡夫卡同步制作人,什么是卡夫卡异步制作人?例如,这里的一个主题有三个分区。Kafka synchronous producer:当这个producer写一个消息时,它立即将它发送到一个分区。
答案:1。概述Kafka是Apache Software Foundation开发的开源流处理平台,由Scala和Java编写。Kafka是一个高吞吐量的分布式发布订阅消息系统,可以处理网站中消费者的所有动作流数据。