InternalKafkaConsumer

InternalKafkaConsumer is…​FIXME

Getting Single Kafka ConsumerRecord — get Method

get(
  offset: Long,
  untilOffset: Long,
  pollTimeoutMs: Long,
  failOnDataLoss: Boolean): ConsumerRecord[Array[Byte], Array[Byte]]

get…​FIXME

Note
 get is used when…​FIXME

Getting Single AvailableOffsetRange — getAvailableOffsetRange Method

getAvailableOffsetRange(): AvailableOffsetRange

getAvailableOffsetRange…​FIXME

Note
 getAvailableOffsetRange is used when…​FIXME

results matching ""

    No results matching ""