net.researchgate.kafka.metamorph

Interface PartitionConsumerProvider

public interface PartitionConsumerProvider

Interface to get configured instance of PartitionConsumer without explicit Kafka version specification.

Method Summary

Modifier and Type	Method and Description
<K,V> PartitionConsumer<K,V>	createConsumer(java.util.Properties properties)
<K,V> PartitionConsumer<K,V>	createConsumer(java.util.Properties properties, java.lang.Object keyDeserializer, java.lang.Object valueDeserializer) Creates consumer with key/value-decoder/deserializer instances passed.

Method Detail

createConsumer

<K,V> PartitionConsumer<K,V> createConsumer(java.util.Properties properties,
                                            java.lang.Object keyDeserializer,
                                            java.lang.Object valueDeserializer)

Creates consumer with key/value-decoder/deserializer instances passed. Discouraged in favor of createConsumer(Properties) which doesn't require to create deserializer instances.

Type Parameters:

K - - key class

V - - value class

Parameters:

properties - - consumer properties, see ConsumerConfig for the details. For Kafka 08 only listed properties are supported, for greater versions all consumer properties.

keyDeserializer - - implementation-specific decoder/deserializer for the key

valueDeserializer - - implementation-specific decoder/deserializer for the key

Returns:

configured partition consumer

createConsumer

<K,V> PartitionConsumer<K,V> createConsumer(java.util.Properties properties)

Type Parameters:

K - - key class

V - - value class

Parameters:

properties - - consumer properties, see ConsumerConfig for the details

Returns:

configured partition consumer with dynamically created and configured key/value deserializers