所有方法 实例方法 具体方法
| 限定符和类型 |
方法和说明 |
void |
addInterceptor(ProducerInterceptor interceptor) |
List<SendResult> |
batchSend(List<ProduceMessage> messages) |
List<SendResult> |
batchSend(List<ProduceMessage> messages,
long timeout,
TimeUnit timeoutUnit) |
CompletableFuture<List<SendResult>> |
batchSendAsync(List<ProduceMessage> messages) |
CompletableFuture<List<SendResult>> |
batchSendAsync(List<ProduceMessage> messages,
long timeout,
TimeUnit timeoutUnit) |
void |
batchSendOneway(List<ProduceMessage> messages) |
void |
batchSendOneway(List<ProduceMessage> messages,
long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
beginTransaction() |
TransactionMessageProducer |
beginTransaction(long timeout,
TimeUnit timeoutUnit) |
TransactionMessageProducer |
beginTransaction(String transactionId) |
TransactionMessageProducer |
beginTransaction(String transactionId,
long timeout,
TimeUnit timeoutUnit) |
protected void |
checkState() |
protected List<SendResult> |
doBatchSend(List<ProduceMessage> messages,
long timeout,
TimeUnit timeoutUnit,
boolean isOneway,
AsyncBatchProduceCallback callback) |
protected SendResult |
doSend(ProduceMessage message,
long timeout,
TimeUnit timeoutUnit,
boolean isOneway,
AsyncProduceCallback callback) |
protected void |
doStart() |
protected void |
doStop() |
TopicMetadata |
getTopicMetadata(String topic) |
void |
removeInterceptor(ProducerInterceptor interceptor) |
SendResult |
send(ProduceMessage message) |
SendResult |
send(ProduceMessage message,
long timeout,
TimeUnit timeoutUnit) |
CompletableFuture<SendResult> |
sendAsync(ProduceMessage message) |
CompletableFuture<SendResult> |
sendAsync(ProduceMessage message,
long timeout,
TimeUnit timeoutUnit) |
void |
sendOneway(ProduceMessage message) |
void |
sendOneway(ProduceMessage message,
long timeout,
TimeUnit timeoutUnit) |
protected void |
validate() |