org.springframework.kafka.test.utils

Class KafkaTestUtils

java.lang.Object

org.springframework.kafka.test.utils.KafkaTestUtils

public final class KafkaTestUtils
extends java.lang.Object

Kafka testing utilities.

Author:

Gary Russell

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

consumerProps

public 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.

Parameters:

group - the group id.

autoCommit - the auto commit.

embeddedKafka - a KafkaEmbedded instance.

Returns:

the properties.

producerProps

public static java.util.Map<java.lang.String,java.lang.Object> producerProps(KafkaEmbedded embeddedKafka)

Set up test properties for an <Integer, String> producer.

Parameters:

embeddedKafka - a KafkaEmbedded instance.

Returns:

the properties.

consumerProps

public static java.util.Map<java.lang.String,java.lang.Object> consumerProps(java.lang.String brokers,
                                                                             java.lang.String group,
                                                                             java.lang.String autoCommit)

senderProps

public static java.util.Map<java.lang.String,java.lang.Object> senderProps(java.lang.String brokers)