接口的使用
wang.bigbird.domain.framework.data.kafka.handler.InProducerTransactionJobHandler

使用InProducerTransactionJobHandler的程序包

程序包	说明
wang.bigbird.domain.framework.data.kafka.service
wang.bigbird.domain.framework.data.kafka.service.impl

wang.bigbird.domain.framework.data.kafka.service中InProducerTransactionJobHandler的使用

参数类型为InProducerTransactionJobHandler的wang.bigbird.domain.framework.data.kafka.service中的方法

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

wang.bigbird.domain.framework.data.kafka.service.impl中InProducerTransactionJobHandler的使用

参数类型为InProducerTransactionJobHandler的wang.bigbird.domain.framework.data.kafka.service.impl中的方法

限定符和类型	方法和说明
org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,byte[]>>	KafkaProducerServiceImpl.sendAsync(String topic, byte[] message, InProducerTransactionJobHandler jobHandler)
org.springframework.util.concurrent.ListenableFuture<org.springframework.kafka.support.SendResult<String,Object>>	KafkaProducerServiceImpl.sendAsync(String topic, Object message, InProducerTransactionJobHandler jobHandler)
void	KafkaProducerServiceImpl.sendSync(String topic, byte[] message, InProducerTransactionJobHandler jobHandler)
void	KafkaProducerServiceImpl.sendSync(String topic, Object message, InProducerTransactionJobHandler jobHandler)