InternalKafkaConsumer is…FIXME
Getting Single Kafka ConsumerRecord — get Method
|
|
get( offset: Long, untilOffset: Long, pollTimeoutMs: Long, failOnDataLoss: Boolean): ConsumerRecord[Array[Byte], Array[Byte]] |
|
Note
|
get is used when…FIXME
|
Getting Single AvailableOffsetRange — getAvailableOffsetRange Method
|
|
getAvailableOffsetRange(): AvailableOffsetRange |
getAvailableOffsetRange…FIXME
|
Note
|
getAvailableOffsetRange is used when…FIXME
|
spark技术分享
