Package 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	Description
static String	BROKER_ID
static int	DEFAULT_BROKER_ID
static String	DEFAULT_KAFKA_BROKER
static int	DEFAULT_KAFKA_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

Method Summary

Modifier and Type	Method	Description
static void	configureHostName(Properties configuration, String hostName)
static void	configureOffsetsTopicReplicationFactor(Properties configuration, short replicationFactor)
static void	configureTopicDeletion(Properties configuration, boolean topicDeletionEnabled)
static void	configureTransactionStateLogReplicationFactor(Properties configuration, short replicationFactor)
static Properties	getDefaultKafkaConfiguration()
static Properties	getDefaultKafkaConfiguration(ZkStarter.ZookeeperInstance zookeeperInstance)
static String	getDefaultKafkaZKAddress()
static Properties	getTopicCreationProps(int numKafkaPartitions)
static org.apache.pinot.spi.stream.StreamDataServerStartable	startServer(int port, int brokerId, String zkStr, Properties baseConf)
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_KAFKA_PORT

public static final int DEFAULT_KAFKA_PORT

See Also:

Constant Field Values

DEFAULT_KAFKA_BROKER

public static final String DEFAULT_KAFKA_BROKER

See Also:

Constant Field Values

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

Method Detail

getDefaultKafkaConfiguration

public static Properties getDefaultKafkaConfiguration()

configureOffsetsTopicReplicationFactor

public static void configureOffsetsTopicReplicationFactor(Properties configuration,
                                                          short replicationFactor)

configureTransactionStateLogReplicationFactor

public static void configureTransactionStateLogReplicationFactor(Properties configuration,
                                                                 short replicationFactor)

configureTopicDeletion

public static void configureTopicDeletion(Properties configuration,
                                          boolean topicDeletionEnabled)

configureHostName

public static void configureHostName(Properties configuration,
                                     String hostName)

getDefaultKafkaZKAddress

public static String getDefaultKafkaZKAddress()

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 baseConf)

getDefaultKafkaConfiguration

public static Properties getDefaultKafkaConfiguration(ZkStarter.ZookeeperInstance zookeeperInstance)