Package io.eventuate.messaging.kafka.basic.consumer

Class DefaultKafkaMessageConsumer

java.lang.Object

io.eventuate.messaging.kafka.basic.consumer.DefaultKafkaMessageConsumer

All Implemented Interfaces:

KafkaMessageConsumer

public class DefaultKafkaMessageConsumer
extends Object
implements KafkaMessageConsumer

Method Summary

Modifier and Type	Method	Description
void	assign(Collection<org.apache.kafka.common.TopicPartition> topicPartitions)
void	close()
void	close(Duration duration)
void	commitOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)
static KafkaMessageConsumer	create(Properties properties)
List<org.apache.kafka.common.PartitionInfo>	partitionsFor(String topic)
void	pause(Set<org.apache.kafka.common.TopicPartition> partitions)
org.apache.kafka.clients.consumer.ConsumerRecords<String,byte[]>	poll(Duration duration)
long	position(org.apache.kafka.common.TopicPartition topicPartition)
void	resume(Set<org.apache.kafka.common.TopicPartition> partitions)
void	seek(org.apache.kafka.common.TopicPartition topicPartition, long position)
void	seekToEnd(Collection<org.apache.kafka.common.TopicPartition> topicPartitions)
void	subscribe(Collection<String> topics, org.apache.kafka.clients.consumer.ConsumerRebalanceListener callback)
void	subscribe(List<String> topics)

Methods inherited from class java.lang.Object

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

Method Details

create

public static KafkaMessageConsumer create(Properties properties)

assign

public void assign(Collection<org.apache.kafka.common.TopicPartition> topicPartitions)

Specified by:

assign in interface KafkaMessageConsumer

seekToEnd

public void seekToEnd(Collection<org.apache.kafka.common.TopicPartition> topicPartitions)

Specified by:

seekToEnd in interface KafkaMessageConsumer

position

public long position(org.apache.kafka.common.TopicPartition topicPartition)

Specified by:

position in interface KafkaMessageConsumer

seek

public void seek(org.apache.kafka.common.TopicPartition topicPartition,
 long position)

Specified by:

seek in interface KafkaMessageConsumer

subscribe

public void subscribe(List<String> topics)

Specified by:

subscribe in interface KafkaMessageConsumer

subscribe

public void subscribe(Collection<String> topics,
 org.apache.kafka.clients.consumer.ConsumerRebalanceListener callback)

Specified by:

subscribe in interface KafkaMessageConsumer

commitOffsets

public void commitOffsets(Map<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets)

Specified by:

commitOffsets in interface KafkaMessageConsumer

partitionsFor

public List<org.apache.kafka.common.PartitionInfo> partitionsFor(String topic)

Specified by:

partitionsFor in interface KafkaMessageConsumer

poll

public org.apache.kafka.clients.consumer.ConsumerRecords<String,byte[]> poll(Duration duration)

Specified by:

poll in interface KafkaMessageConsumer

pause

public void pause(Set<org.apache.kafka.common.TopicPartition> partitions)

Specified by:

pause in interface KafkaMessageConsumer

resume

public void resume(Set<org.apache.kafka.common.TopicPartition> partitions)

Specified by:

resume in interface KafkaMessageConsumer

close

public void close()

Specified by:

close in interface KafkaMessageConsumer

close

public void close(Duration duration)

Specified by:

close in interface KafkaMessageConsumer