public static class KafkaTestEnvironment.Config extends Object
| Modifier and Type | Method and Description |
|---|---|
Properties |
getKafkaServerProperties() |
int |
getKafkaServersNumber() |
boolean |
isSecureMode() |
KafkaTestEnvironment.Config |
setKafkaServerProperties(Properties kafkaServerProperties) |
KafkaTestEnvironment.Config |
setKafkaServersNumber(int kafkaServersNumber) |
KafkaTestEnvironment.Config |
setSecureMode(boolean secureMode) |
public int getKafkaServersNumber()
public KafkaTestEnvironment.Config setKafkaServersNumber(int kafkaServersNumber)
public Properties getKafkaServerProperties()
public KafkaTestEnvironment.Config setKafkaServerProperties(Properties kafkaServerProperties)
public boolean isSecureMode()
public KafkaTestEnvironment.Config setSecureMode(boolean secureMode)
Copyright © 2019. All rights reserved.