Deprecated API

Contents

• Deprecated Exceptions
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

Deprecated Exceptions

Exceptions and Description
org.apache.kafka.common.errors.GroupCoordinatorNotAvailableException As of Kafka 0.11, this has been replaced by CoordinatorNotAvailableException
org.apache.kafka.common.errors.GroupLoadInProgressException As of Kafka 0.11, this has been replaced by CoordinatorLoadInProgressException
org.apache.kafka.common.errors.NotCoordinatorForGroupException As of Kafka 0.11, this has been replaced by NotCoordinatorException

Deprecated Fields

Field and Description
org.apache.kafka.streams.StreamsConfig.KEY_SERDE_CLASS_CONFIG Use StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.TIMESTAMP_EXTRACTOR_CLASS_CONFIG Use StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.VALUE_SERDE_CLASS_CONFIG Use StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.ZOOKEEPER_CONNECT_CONFIG Kakfa Streams does not use Zookeeper anymore and this parameter will be ignored.

Deprecated Methods

Method and Description
org.apache.kafka.clients.consumer.ConsumerRecord.checksum() As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the checksum returned by the broker may not match what was computed by the producer. It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally, message format v2 does not include a record-level checksum (for performance, the record checksum was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from the record timestamp, serialized key size, and serialized value size is returned instead, but this should not be depended on for end-to-end reliability.
org.apache.kafka.clients.producer.RecordMetadata.checksum() As of Kafka 0.11.0. Because of the potential for message format conversion on the broker, the computed checksum may not match what was stored on the broker, or what will be returned to the consumer. It is therefore unsafe to depend on this checksum for end-to-end delivery guarantees. Additionally, message format v2 does not include a record-level checksum (for performance, the record checksum was replaced with a batch checksum). To maintain compatibility, a partial checksum computed from the record timestamp, serialized key size, and serialized value size is returned instead, but this should not be depended on for end-to-end reliability.
org.apache.kafka.streams.kstream.KTable.foreach(ForeachAction) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.foreach(ForeachAction)} on the result.
org.apache.kafka.streams.StreamsConfig.keySerde()
org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(Collection) Use SinkTask.open(Collection) for partition initialization.
org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(Collection) Use SinkTask.close(Collection) instead for partition cleanup.
org.apache.kafka.clients.consumer.NoOffsetForPartitionException.partition() please use NoOffsetForPartitionException.partitions
org.apache.kafka.streams.kstream.KTable.print() Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.print() on the result.
org.apache.kafka.streams.kstream.KTable.print(Serde, Serde) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.print(Serde, Serde) on the result.
org.apache.kafka.streams.kstream.KTable.print(Serde, Serde, String) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.print(Serde, Serde, String) on the result.
org.apache.kafka.streams.kstream.KTable.print(String) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.print(String) on the result.
org.apache.kafka.streams.StreamsConfig.valueSerde()
org.apache.kafka.streams.kstream.KTable.writeAsText(String) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.writeAsText(String)} on the result.
org.apache.kafka.streams.kstream.KTable.writeAsText(String, Serde, Serde) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.writeAsText(String, Serde, Serde)} on the result.
org.apache.kafka.streams.kstream.KTable.writeAsText(String, String) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.writeAsText(String, String)} on the result.
org.apache.kafka.streams.kstream.KTable.writeAsText(String, String, Serde, Serde) Use the Interactive Queries APIs (e.g., KafkaStreams.store(String, QueryableStoreType) followed by ReadOnlyKeyValueStore.all()) to iterate over the keys of a KTable. Alternatively convert to a KStream using toStream() and then use KStream.writeAsText(String, String, Serde, Serde)} on the result.

Deprecated Constructors

Constructor and Description
org.apache.kafka.clients.producer.RecordMetadata(TopicPartition, long, long, long, long, int, int) As of 0.11.0. Use @RecordMetadata.RecordMetadata(TopicPartition, long, long, long, Long, int, int).