public class MessageHandlingAppTest extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
private ConsoleLogger |
logger
|
private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> |
producer
|
private static long |
serialVersionUID
|
Constructor and Description |
---|
MessageHandlingAppTest() |
Modifier and Type | Method and Description |
---|---|
void |
generatePresetCommand() |
void |
init() |
private void |
init(String[] args)
|
static void |
main(String[] args)
|
private static final long serialVersionUID
private org.apache.kafka.clients.producer.KafkaProducer<String,byte[]> producer
private ConsoleLogger logger