Uses of Class
io.druid.firehose.kafka.KafkaSimpleConsumer.BytesMessageWithOffset

Packages that use KafkaSimpleConsumer.BytesMessageWithOffset

Package	Description
io.druid.firehose.kafka

Uses of KafkaSimpleConsumer.BytesMessageWithOffset in io.druid.firehose.kafka

Fields in io.druid.firehose.kafka with type parameters of type KafkaSimpleConsumer.BytesMessageWithOffset

Modifier and Type	Field and Description
static List<KafkaSimpleConsumer.BytesMessageWithOffset>	KafkaSimpleConsumer.EMPTY_MSGS

Methods in io.druid.firehose.kafka that return types with arguments of type KafkaSimpleConsumer.BytesMessageWithOffset

Modifier and Type	Method and Description
Iterable<KafkaSimpleConsumer.BytesMessageWithOffset>	KafkaSimpleConsumer.fetch(long offset, int timeoutMs)