org.apache.pinot.tools.utils

Class KafkaStarterUtils

java.lang.Object

org.apache.pinot.tools.utils.KafkaStarterUtils

public class KafkaStarterUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	BROKER_ID
static int	DEFAULT_BROKER_ID
static String	DEFAULT_KAFKA_BROKER
static int	DEFAULT_KAFKA_PORT
static String	DEFAULT_ZK_STR
static int	DEFAULT_ZK_TEST_PORT
static String	KAFKA_JSON_MESSAGE_DECODER_CLASS_NAME
static String	KAFKA_PRODUCER_CLASS_NAME
static String	KAFKA_SERVER_STARTABLE_CLASS_NAME
static String	KAFKA_STREAM_CONSUMER_FACTORY_CLASS_NAME
static String	KAFKA_STREAM_LEVEL_CONSUMER_CLASS_NAME
static String	PORT
static String	ZOOKEEPER_CONNECT

Constructor Summary

Constructors

Constructor and Description
KafkaStarterUtils()

Method Summary

Modifier and Type	Method and Description
static void	configureHostName(Properties configuration, String hostName)
static void	configureOffsetsTopicReplicationFactor(Properties configuration, short replicationFactor)
static void	configureTopicDeletion(Properties configuration, boolean topicDeletionEnabled)
static Properties	getDefaultKafkaConfiguration()
static Properties	getTopicCreationProps(int numKafkaPartitions)
static org.apache.pinot.spi.stream.StreamDataServerStartable	startServer(int port, int brokerId, String zkStr, Properties configuration)
static List<org.apache.pinot.spi.stream.StreamDataServerStartable>	startServers(int brokerCount, int port, String zkStr, Properties configuration)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_BROKER_ID

public static final int DEFAULT_BROKER_ID

See Also:

Constant Field Values

DEFAULT_ZK_TEST_PORT

public static final int DEFAULT_ZK_TEST_PORT

See Also:

Constant Field Values

DEFAULT_ZK_STR

public static final String DEFAULT_ZK_STR

See Also:

Constant Field Values

DEFAULT_KAFKA_PORT

public static int DEFAULT_KAFKA_PORT

DEFAULT_KAFKA_BROKER

public static final String DEFAULT_KAFKA_BROKER

PORT

public static final String PORT

See Also:

Constant Field Values

BROKER_ID

public static final String BROKER_ID

See Also:

Constant Field Values

ZOOKEEPER_CONNECT

public static final String ZOOKEEPER_CONNECT

See Also:

Constant Field Values

KAFKA_SERVER_STARTABLE_CLASS_NAME

public static final String KAFKA_SERVER_STARTABLE_CLASS_NAME

KAFKA_PRODUCER_CLASS_NAME

public static final String KAFKA_PRODUCER_CLASS_NAME

KAFKA_STREAM_CONSUMER_FACTORY_CLASS_NAME

public static final String KAFKA_STREAM_CONSUMER_FACTORY_CLASS_NAME

KAFKA_STREAM_LEVEL_CONSUMER_CLASS_NAME

public static final String KAFKA_STREAM_LEVEL_CONSUMER_CLASS_NAME

KAFKA_JSON_MESSAGE_DECODER_CLASS_NAME

public static final String KAFKA_JSON_MESSAGE_DECODER_CLASS_NAME

See Also:

Constant Field Values

Constructor Detail

KafkaStarterUtils

public KafkaStarterUtils()

Method Detail

getDefaultKafkaConfiguration

public static Properties getDefaultKafkaConfiguration()

configureOffsetsTopicReplicationFactor

public static void configureOffsetsTopicReplicationFactor(Properties configuration,
                                                          short replicationFactor)

configureTopicDeletion

public static void configureTopicDeletion(Properties configuration,
                                          boolean topicDeletionEnabled)

configureHostName

public static void configureHostName(Properties configuration,
                                     String hostName)

getTopicCreationProps

public static Properties getTopicCreationProps(int numKafkaPartitions)

startServers

public static List<org.apache.pinot.spi.stream.StreamDataServerStartable> startServers(int brokerCount,
                                                                                       int port,
                                                                                       String zkStr,
                                                                                       Properties configuration)

startServer

public static org.apache.pinot.spi.stream.StreamDataServerStartable startServer(int port,
                                                                                int brokerId,
                                                                                String zkStr,
                                                                                Properties configuration)