| Package | Description |
|---|---|
| com.github.ydespreaux.testcontainers.kafka.cmd | |
| com.github.ydespreaux.testcontainers.kafka.containers | |
| com.github.ydespreaux.testcontainers.kafka.rule |
| Constructor and Description |
|---|
AclsAddCmd(Certificates certificates) |
| Modifier and Type | Method and Description |
|---|---|
KafkaContainer |
KafkaContainer.withKafkaClientCertificates(Certificates certificates) |
KafkaContainer |
KafkaContainer.withKafkaServerCertificates(Certificates certificates) |
SchemaRegistryContainer |
SchemaRegistryContainer.withServerCertificates(Certificates certificates) |
KafkaConnectContainer |
KafkaConnectContainer.withServerCertificates(Certificates certificates) |
| Modifier and Type | Method and Description |
|---|---|
Certificates |
ConfluentKafkaContainer.getKafkaClientCertificates() |
Certificates |
ConfluentKafkaContainer.getKafkaServerCertificates() |
| Modifier and Type | Method and Description |
|---|---|
S |
ConfluentKafkaContainer.withAcls(Certificates certificates,
AclsOperation[] operations,
String topic,
String group) |
S |
ConfluentKafkaContainer.withAcls(Certificates certificates,
AclsOperation operation,
String topic,
String group) |
S |
ConfluentKafkaContainer.withAllAcls(Certificates certificates,
String topic,
String group) |
S |
ConfluentKafkaContainer.withDescribeAcls(Certificates certificates,
String topic,
String group) |
S |
ConfluentKafkaContainer.withKafkaClientCertificates(Certificates certificates) |
ConfluentKafkaConnectContainer |
ConfluentKafkaConnectContainer.withKafkaConnectCertificates(Certificates certificates) |
S |
ConfluentKafkaContainer.withKafkaServerCertificates(Certificates certificates) |
S |
ConfluentKafkaContainer.withReadAcls(Certificates certificates,
String topic,
String group) |
S |
ConfluentKafkaContainer.withWriteAcls(Certificates certificates,
String topic) |
Copyright © 2019. All rights reserved.