Package com.networknt.tram.test

Interface KafkaTestEnvironment.KafkaOffsetHandler

Enclosing interface:

KafkaTestEnvironment

public static interface KafkaTestEnvironment.KafkaOffsetHandler

Simple interface to commit and retrieve offsets.

Method Summary

Modifier and Type	Method	Description
void	close()
Long	getCommittedOffset(String topicName, int partition)
void	setCommittedOffset(String topicName, int partition, long offset)

Method Detail

getCommittedOffset

Long getCommittedOffset(String topicName,
                        int partition)

setCommittedOffset

void setCommittedOffset(String topicName,
                        int partition,
                        long offset)

close

void close()