Github user koeninger commented on a diff in the pull request:
https://github.com/apache/spark/pull/21917#discussion_r207721492
--- Diff:
external/kafka-0-10/src/main/scala/org/apache/spark/streaming/kafka010/KafkaDataConsumer.scala
---
@@ -191,6 +211,11 @@ private[kafka010] class InternalKafkaConsumer[K, V](
buffer.previous()
}
+ def seekAndPoll(offset: Long, timeout: Long): ConsumerRecords[K, V] = {
--- End diff --
Is this used anywhere?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
