public class KafkaContainerClient extends Object
KafkaContainer
.Constructor and Description |
---|
KafkaContainerClient(org.testcontainers.containers.KafkaContainer container) |
Modifier and Type | Method and Description |
---|---|
void |
createTopic(int replicationFactor,
int numPartitions,
String topic) |
<T> List<T> |
readMessages(int expectedNumMessages,
String groupId,
String topic,
org.apache.kafka.common.serialization.Deserializer<T> valueDeserializer) |
<T> void |
sendMessages(String topic,
org.apache.kafka.common.serialization.Serializer<T> valueSerializer,
T... messages) |
public KafkaContainerClient(org.testcontainers.containers.KafkaContainer container)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.