wang.bigbird.domain.framework.data.kafka.service.impl

类 KafkaProducerServiceImpl

java.lang.Object

wang.bigbird.domain.framework.data.kafka.service.impl.KafkaProducerServiceImpl

所有已实现的接口:

KafkaProducerService

@Service
public class KafkaProducerServiceImpl
extends Object
implements KafkaProducerService

kafka生产者服务

作者:

Bigbird

构造器概要

构造器

构造器和说明
KafkaProducerServiceImpl()

方法概要

限定符和类型	方法和说明
org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,byte[]>>	sendAsync(String topic, byte[] message, InProducerTransactionJobHandler jobHandler) 执行异步发送消息
org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,Object>>	sendAsync(String topic, Object message, InProducerTransactionJobHandler jobHandler) 执行异步发送消息
void	sendSync(String topic, byte[] message, InProducerTransactionJobHandler jobHandler) 执行同步发送消息
void	sendSync(String topic, Object message, InProducerTransactionJobHandler jobHandler) 执行同步发送消息

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

KafkaProducerServiceImpl

public KafkaProducerServiceImpl()

方法详细资料

sendSync

public void sendSync(String topic,
                     Object message,
                     InProducerTransactionJobHandler jobHandler)

从接口复制的说明: KafkaProducerService

执行同步发送消息

指定者:

sendSync 在接口中 KafkaProducerService

参数:

topic - 主题

message - 消息

jobHandler - 后继处理任务，一般用于开启事务模式下，消息发送到broke后的后续任务处理

sendSync

public void sendSync(String topic,
                     byte[] message,
                     InProducerTransactionJobHandler jobHandler)

从接口复制的说明: KafkaProducerService

执行同步发送消息

指定者:

sendSync 在接口中 KafkaProducerService

参数:

topic - 主题

message - 消息

jobHandler - 后继处理任务，一般用于开启事务模式下，消息发送到broke后的后续任务处理

sendAsync

public org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,Object>> sendAsync(String topic,
                                                                                                                                   Object message,
                                                                                                                                   InProducerTransactionJobHandler jobHandler)

从接口复制的说明: KafkaProducerService

执行异步发送消息

指定者:

sendAsync 在接口中 KafkaProducerService

参数:

topic - 主题

message - 消息

jobHandler - 后继处理任务，一般用于开启事务模式下，消息发送到broke后的后续任务处理

返回:

ListenableFuture

sendAsync

public org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,byte[]>> sendAsync(String topic,
                                                                                                                                   byte[] message,
                                                                                                                                   InProducerTransactionJobHandler jobHandler)

从接口复制的说明: KafkaProducerService

执行异步发送消息

指定者:

sendAsync 在接口中 KafkaProducerService

参数:

topic - 主题

message - 消息

jobHandler - 后继处理任务，一般用于开启事务模式下，消息发送到broke后的后续任务处理

返回:

ListenableFuture