KafkaContainer |
KafkaContainer.withAcls(List<AclsAddCmd> commands) |
KafkaContainer |
KafkaContainer.withBrokerServersSystemProperty(String brokerServersSystemProperty) |
KafkaContainer |
KafkaContainer.withFormatMessageVersion(String version)
Set of the message compatibility version.
|
KafkaContainer |
KafkaContainer.withIdentificationAlgorithmSystemProperty(String identificationAlgorithmSystemProperty) |
KafkaContainer |
KafkaContainer.withKafkaClientCertificates(Certificates certificates) |
KafkaContainer |
KafkaContainer.withKafkaServerCertificates(Certificates certificates) |
KafkaContainer |
KafkaContainer.withKeyPasswordSystemProperty(String keyPasswordSystemProperty) |
KafkaContainer |
KafkaContainer.withKeystoreLocationSystemProperty(String keystoreLocationSystemProperty) |
KafkaContainer |
KafkaContainer.withKeystorePasswordSystemProperty(String keystorePasswordSystemProperty) |
KafkaContainer |
KafkaContainer.withRegisterSpringbootProperties(boolean registerProperties) |
KafkaContainer |
KafkaContainer.withSecurityProtocolSystemProperty(String securityProtocolSystemProperty) |
KafkaContainer |
KafkaContainer.withTopics(List<TopicConfiguration> topics) |
KafkaContainer |
KafkaContainer.withTruststoreLocationSystemProperty(String truststoreLocationSystemProperty) |
KafkaContainer |
KafkaContainer.withTruststorePasswordSystemProperty(String truststorePasswordSystemProperty) |
KafkaContainer |
KafkaContainer.withZookeeperHostname(String zookeeperHostname) |
KafkaContainer |
KafkaContainer.withZookeeperPort(Integer port)
Set the zookeeper port.
|