程序包 com.cdkjframework.kafka.producer.util

类 ProducerUtils

java.lang.Object

com.cdkjframework.kafka.producer.util.ProducerUtils

public class ProducerUtils
extends Object

构造器概要

构造器

构造器	说明
ProducerUtils()

方法概要

修饰符和类型	方法	说明
static void	sendMessageAsync(String topic, String message)	producer 异步方式发送数据
static void	sendMessageAsync(String topic, String key, String message)	producer 异步方式发送数据
static void	sendMessageSync(String topic, String message)	producer 同步方式发送数据

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

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

构造器详细资料

ProducerUtils

public ProducerUtils()

方法详细资料

sendMessageSync

public static void sendMessageSync(String topic,
 String message)
                            throws InterruptedException,
ExecutionException,
TimeoutException

producer 同步方式发送数据

参数:

topic - topic名称

message - producer发送的数据

抛出:

InterruptedException - 异常信息

ExecutionException - 异常信息

TimeoutException - 异常信息

sendMessageAsync

public static void sendMessageAsync(String topic,
 String message)
                             throws ExecutionException,
InterruptedException,
TimeoutException

producer 异步方式发送数据

参数:

topic - topic名称

message - producer发送的数据

抛出:

ExecutionException

InterruptedException

TimeoutException

sendMessageAsync

public static void sendMessageAsync(String topic,
 String key,
 String message)
                             throws ExecutionException,
InterruptedException,
TimeoutException

producer 异步方式发送数据

参数:

topic - topic名称

key - key值

message - producer发送的数据

抛出:

ExecutionException

InterruptedException

TimeoutException