com.networknt.tram.test

Interface KafkaTestEnvironment

All Known Implementing Classes:

KafkaTestEnvironmentImpl

public interface KafkaTestEnvironment

Abstract class providing a Kafka test environment.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	KafkaTestEnvironment.Config
static interface	KafkaTestEnvironment.KafkaOffsetHandler Simple interface to commit and retrieve offsets.

Field Summary

Fields

Modifier and Type	Field and Description
static String	KAFKA_HOST

Method Summary

Modifier and Type	Method and Description
static KafkaTestEnvironment.Config	createConfig()
KafkaTestEnvironment.KafkaOffsetHandler	createOffsetHandler()
void	createTestTopic(String topic, int numberOfPartitions, short replicationFactor)
void	createTestTopic(String topic, int numberOfPartitions, short replicationFactor, Properties properties)
void	deleteTestTopic(String topic)
<K,V> Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>>	getAllRecordsFromTopic(Properties properties, String topic, int partition, long timeout)
String	getBrokerConnectionString()
int	getBrokerId(kafka.server.KafkaServer server)
List<kafka.server.KafkaServer>	getBrokers()
int	getLeaderToShutDown(String topic)
Properties	getSecureProperties()
Properties	getStandardProperties()
String	getVersion()
boolean	isSecureRunSupported()
void	prepare(KafkaTestEnvironment.Config config)
void	restartBroker(int leaderId)
void	shutdown()

Field Detail

KAFKA_HOST

static final String KAFKA_HOST

See Also:

Constant Field Values

Method Detail

createConfig

static KafkaTestEnvironment.Config createConfig()

prepare

void prepare(KafkaTestEnvironment.Config config)

shutdown

void shutdown()

deleteTestTopic

void deleteTestTopic(String topic)

createTestTopic

void createTestTopic(String topic,
                     int numberOfPartitions,
                     short replicationFactor,
                     Properties properties)

createTestTopic

void createTestTopic(String topic,
                     int numberOfPartitions,
                     short replicationFactor)

getStandardProperties

Properties getStandardProperties()

getSecureProperties

Properties getSecureProperties()

getBrokerConnectionString

String getBrokerConnectionString()

getVersion

String getVersion()

getBrokers

List<kafka.server.KafkaServer> getBrokers()

getAllRecordsFromTopic

<K,V> Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>> getAllRecordsFromTopic(Properties properties,
                                                                                               String topic,
                                                                                               int partition,
                                                                                               long timeout)

createOffsetHandler

KafkaTestEnvironment.KafkaOffsetHandler createOffsetHandler()

restartBroker

void restartBroker(int leaderId)
            throws Exception

Throws:

Exception

getLeaderToShutDown

int getLeaderToShutDown(String topic)
                 throws Exception

Throws:

Exception

getBrokerId

int getBrokerId(kafka.server.KafkaServer server)

isSecureRunSupported

boolean isSecureRunSupported()