public final class KafkaTestUtils
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
static java.util.Map<java.lang.String,java.lang.Object> |
consumerProps(java.lang.String group,
java.lang.String autoCommit,
KafkaEmbedded embeddedKafka)
Set up test properties for an
<Integer, String> consumer. |
static java.util.Map<java.lang.String,java.lang.Object> |
consumerProps(java.lang.String brokers,
java.lang.String group,
java.lang.String autoCommit) |
static java.util.Map<java.lang.String,java.lang.Object> |
producerProps(KafkaEmbedded embeddedKafka)
Set up test properties for an
<Integer, String> producer. |
static java.util.Map<java.lang.String,java.lang.Object> |
senderProps(java.lang.String brokers) |
public static java.util.Map<java.lang.String,java.lang.Object> consumerProps(java.lang.String group,
java.lang.String autoCommit,
KafkaEmbedded embeddedKafka)
<Integer, String> consumer.group - the group id.autoCommit - the auto commit.embeddedKafka - a KafkaEmbedded instance.public static java.util.Map<java.lang.String,java.lang.Object> producerProps(KafkaEmbedded embeddedKafka)
<Integer, String> producer.embeddedKafka - a KafkaEmbedded instance.public static java.util.Map<java.lang.String,java.lang.Object> consumerProps(java.lang.String brokers,
java.lang.String group,
java.lang.String autoCommit)
public static java.util.Map<java.lang.String,java.lang.Object> senderProps(java.lang.String brokers)