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, Hugo Wood

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) Set up test properties for an <Integer, String> consumer.
static java.lang.Object	getPropertyValue(java.lang.Object root, java.lang.String propertyPath) Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g.
static <T> T	getPropertyValue(java.lang.Object root, java.lang.String propertyPath, java.lang.Class<T> type) A typed version of getPropertyValue(Object, String).
static <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	getRecords(org.apache.kafka.clients.consumer.Consumer<K,V> consumer) Poll the consumer for records.
static <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K,V>	getRecords(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, long timeout) Poll the consumer for records.
static <K,V> org.apache.kafka.clients.consumer.ConsumerRecord<K,V>	getSingleRecord(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, java.lang.String topic) Poll the consumer, expecting a single record for the specified topic.
static <K,V> org.apache.kafka.clients.consumer.ConsumerRecord<K,V>	getSingleRecord(org.apache.kafka.clients.consumer.Consumer<K,V> consumer, java.lang.String topic, long timeout) Poll the consumer, expecting a single record for the specified topic.
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) Set up test properties for an <Integer, String> producer.

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)

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

Parameters:

brokers - the bootstrapServers property.

group - the group id.

autoCommit - the auto commit.

Returns:

the properties.

senderProps

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

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

Parameters:

brokers - the bootstrapServers property.

Returns:

the properties.

getSingleRecord

public static <K,V> org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getSingleRecord(org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
                                                                                          java.lang.String topic)

Poll the consumer, expecting a single record for the specified topic.

Type Parameters:

K - the key type.

V - the value type.

Parameters:

consumer - the consumer.

topic - the topic.

Returns:

the record.

Throws:

org.junit.ComparisonFailure - if exactly one record is not received.

See Also:

getSingleRecord(Consumer, String, long)

getSingleRecord

public static <K,V> org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getSingleRecord(org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
                                                                                          java.lang.String topic,
                                                                                          long timeout)

Poll the consumer, expecting a single record for the specified topic.

Type Parameters:

K - the key type.

V - the value type.

Parameters:

consumer - the consumer.

topic - the topic.

timeout - max time in milliseconds to wait for records; forwarded to Consumer.poll(long).

Returns:

the record.

Throws:

org.junit.ComparisonFailure - if exactly one record is not received.

Since:

2.0

getRecords

public static <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K,V> getRecords(org.apache.kafka.clients.consumer.Consumer<K,V> consumer)

Poll the consumer for records.

Type Parameters:

K - the key type.

V - the value type.

Parameters:

consumer - the consumer.

Returns:

the records.

See Also:

getRecords(Consumer, long)

getRecords

public static <K,V> org.apache.kafka.clients.consumer.ConsumerRecords<K,V> getRecords(org.apache.kafka.clients.consumer.Consumer<K,V> consumer,
                                                                                      long timeout)

Poll the consumer for records.

Type Parameters:

K - the key type.

V - the value type.

Parameters:

consumer - the consumer.

timeout - max time in milliseconds to wait for records; forwarded to Consumer.poll(long).

Returns:

the records.

Since:

2.0

getPropertyValue

public static java.lang.Object getPropertyValue(java.lang.Object root,
                                                java.lang.String propertyPath)

Uses nested DirectFieldAccessors to obtain a property using dotted notation to traverse fields; e.g. "foo.bar.baz" will obtain a reference to the baz field of the bar field of foo. Adopted from Spring Integration.

Parameters:

root - The object.

propertyPath - The path.

Returns:

The field.

getPropertyValue

public static <T> T getPropertyValue(java.lang.Object root,
                                     java.lang.String propertyPath,
                                     java.lang.Class<T> type)

A typed version of getPropertyValue(Object, String).

Type Parameters:

T - the type.

Parameters:

root - the object.

propertyPath - the path.

type - the type to cast the object to.

Returns:

the field value.

See Also:

getPropertyValue(Object, String)