Package com.networknt.tram.test

Class KafkaTestEnvironmentImpl

java.lang.Object

com.networknt.tram.test.KafkaTestEnvironmentImpl

All Implemented Interfaces:

KafkaTestEnvironment

public class KafkaTestEnvironmentImpl
extends Object
implements KafkaTestEnvironment

An implementation of the KafkaServerProvider for Kafka 0.11 .

Nested Class Summary

Nested classes/interfaces inherited from interface com.networknt.tram.test.KafkaTestEnvironment

KafkaTestEnvironment.Config, KafkaTestEnvironment.KafkaOffsetHandler

Field Summary

Fields

Modifier and Type	Field	Description
protected static org.slf4j.Logger	LOG

Fields inherited from interface com.networknt.tram.test.KafkaTestEnvironment

KAFKA_HOST

Constructor Summary

Constructors

Constructor	Description
KafkaTestEnvironmentImpl()

Method Summary

Modifier and Type	Method	Description
KafkaTestEnvironment.KafkaOffsetHandler	createOffsetHandler()
void	createTestTopic(String topic, int numberOfPartitions, short replicationFactor)
void	createTestTopic(String topic, int numberOfPartitions, short replicationFactor, Properties topicConfig)
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()
Map<String,Object>	getDefaultClientConfig()
protected kafka.server.KafkaServer	getKafkaServer(int brokerId, File tmpFolder)
int	getLeaderToShutDown(String topic)
Properties	getSecureProperties()
Properties	getStandardProperties()
String	getVersion()
boolean	isSecureRunSupported()
void	prepare(KafkaTestEnvironment.Config config)
void	restartBroker(int leaderId)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

KafkaTestEnvironmentImpl

public KafkaTestEnvironmentImpl()

Method Detail

getBrokerConnectionString

public String getBrokerConnectionString()

Specified by:

getBrokerConnectionString in interface KafkaTestEnvironment

getStandardProperties

public Properties getStandardProperties()

Specified by:

getStandardProperties in interface KafkaTestEnvironment

getSecureProperties

public Properties getSecureProperties()

Specified by:

getSecureProperties in interface KafkaTestEnvironment

getDefaultClientConfig

public Map<String,Object> getDefaultClientConfig()

getVersion

public String getVersion()

Specified by:

getVersion in interface KafkaTestEnvironment

getBrokers

public List<kafka.server.KafkaServer> getBrokers()

Specified by:

getBrokers in interface KafkaTestEnvironment

getAllRecordsFromTopic

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

Specified by:

getAllRecordsFromTopic in interface KafkaTestEnvironment

createOffsetHandler

public KafkaTestEnvironment.KafkaOffsetHandler createOffsetHandler()

Specified by:

createOffsetHandler in interface KafkaTestEnvironment

restartBroker

public void restartBroker(int leaderId)
                   throws Exception

Specified by:

restartBroker in interface KafkaTestEnvironment

Throws:

Exception

getLeaderToShutDown

public int getLeaderToShutDown(String topic)
                        throws Exception

Specified by:

getLeaderToShutDown in interface KafkaTestEnvironment

Throws:

Exception

getBrokerId

public int getBrokerId(kafka.server.KafkaServer server)

Specified by:

getBrokerId in interface KafkaTestEnvironment

isSecureRunSupported

public boolean isSecureRunSupported()

Specified by:

isSecureRunSupported in interface KafkaTestEnvironment

prepare

public void prepare(KafkaTestEnvironment.Config config)

Specified by:

prepare in interface KafkaTestEnvironment

shutdown

public void shutdown()

Specified by:

shutdown in interface KafkaTestEnvironment

createTestTopic

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

Specified by:

createTestTopic in interface KafkaTestEnvironment

createTestTopic

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

Specified by:

createTestTopic in interface KafkaTestEnvironment

deleteTestTopic

public void deleteTestTopic(String topic)

Specified by:

deleteTestTopic in interface KafkaTestEnvironment

getKafkaServer

protected kafka.server.KafkaServer getKafkaServer(int brokerId,
                                                  File tmpFolder)
                                           throws Exception

Throws:

Exception