org.apache.drill.exec.store.kafka

Class KafkaMessageGenerator

java.lang.Object

org.apache.drill.exec.store.kafka.KafkaMessageGenerator

public class KafkaMessageGenerator
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	SCHEMA_REGISTRY_URL

Constructor Summary

Constructors

Constructor and Description
KafkaMessageGenerator(String broker, Class<?> valueSerializer)

Method Summary

Modifier and Type	Method and Description
void	populateAvroMsgIntoKafka(String topic, int numMsg)
void	populateJsonMsgIntoKafka(String topic, int numMsg)
void	populateJsonMsgWithTimestamps(String topic, int numMsg)
void	populateMessages(String topic, String... messages)

Methods inherited from class java.lang.Object

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

Field Detail

SCHEMA_REGISTRY_URL

public static final String SCHEMA_REGISTRY_URL

See Also:

Constant Field Values

Constructor Detail

KafkaMessageGenerator

public KafkaMessageGenerator(String broker,
                             Class<?> valueSerializer)

Method Detail

populateAvroMsgIntoKafka

public void populateAvroMsgIntoKafka(String topic,
                                     int numMsg)

populateJsonMsgIntoKafka

public void populateJsonMsgIntoKafka(String topic,
                                     int numMsg)
                              throws ExecutionException,
                                     InterruptedException

Throws:

ExecutionException

InterruptedException

populateJsonMsgWithTimestamps

public void populateJsonMsgWithTimestamps(String topic,
                                          int numMsg)
                                   throws ExecutionException,
                                          InterruptedException

Throws:

ExecutionException

InterruptedException

populateMessages

public void populateMessages(String topic,
                             String... messages)
                      throws ExecutionException,
                             InterruptedException

Throws:

ExecutionException

InterruptedException