public class ProduceMessageChecker extends Object
| 构造器和说明 |
|---|
ProduceMessageChecker() |
| 限定符和类型 | 方法和说明 |
|---|---|
static void |
checkMessage(ProduceMessage produceMessage,
ProducerConfig config) |
static void |
checkMessages(List<ProduceMessage> produceMessages,
ProducerConfig config) |
protected static void |
throwCheckException(String message) |
public static void checkMessage(ProduceMessage produceMessage, ProducerConfig config)
public static void checkMessages(List<ProduceMessage> produceMessages, ProducerConfig config)
protected static void throwCheckException(String message)
Copyright © 2020 Joyqueue Community. All rights reserved.