org.thales.punch.kafka.api

Interface IKafkaContinuousConsumer

Type Parameters:

K - the class of the record key

V - the class of the record value

All Known Implementing Classes:

KafkaConsumerImpl

public interface IKafkaContinuousConsumer

The IKafkaContinuousConsumer is your main interface to continuously consume kafka topics. You can use is either to consume all partitions, or a given one. Refer to the KafkaContinuousConsumerBuilder class to create and configure your consumer.

Author:

dimi

Method Summary

Modifier and Type	Method and Description
void	close() Close this consumer
void	commit() Commit all the offsets for all the partitions managed by your reader.
int	nextMessages(Duration timeout) Fetch incoming messages, if any.

Method Detail

nextMessages

int nextMessages(Duration timeout)

Fetch incoming messages, if any.

This method is blocking. It encapsulate a call to the underlying KafkaConsumer poll. If some records are fetched from your topic. It will invoke your IRecordHandler in a reentrant manner.

Parameters:

timeout - the blocking timeout in milliseconds

Returns:

the number of records read on all partitions.

commit

void commit()

Commit all the offsets for all the partitions managed by your reader. If you need to work at partition level, use the IPartition interface instead.

close

void close()

Close this consumer