Skip to content


KafkaOffsetReaderConsumer is a KafkaOffsetReader.

KafkaOffsetReaderConsumer is considered old and deprecated (in favour of the new Admin-based KafkaOffsetReaderAdmin).


spark.sql.streaming.kafka.useDeprecatedOffsetFetching configuration property controls what KafkaOffsetReader is used.

Creating Instance

KafkaOffsetReaderConsumer takes the following to be created:

KafkaOffsetReaderConsumer is created when:

String Representation

toString(): String

toString is part of the Object (Java) abstraction.

toString requests the ConsumerStrategy for the string representation.


ConsumerStrategy does not overload toString, but the implementations do (e.g., SubscribeStrategy).

toString is used (among the other uses) when: