Deprecated API

Contents

• Interfaces
• Classes
• Fields
• Methods
• Constructors

Interfaces

Interface	Description
org.apache.kafka.common.security.auth.PrincipalBuilder	As of Kafka 1.0.0, use KafkaPrincipalBuilder instead. This will be removed in a future major release.
org.apache.kafka.common.serialization.ExtendedDeserializer	This class has been deprecated and will be removed in a future release. Please use Deserializer instead.
org.apache.kafka.common.serialization.ExtendedSerializer	This class has been deprecated and will be removed in a future release. Please use Serializer instead.

Classes

Class	Description
org.apache.kafka.common.security.auth.DefaultPrincipalBuilder	As of Kafka 1.0.0. This will be removed in a future major release.

Fields

Field	Description
org.apache.kafka.common.config.SaslConfigs.DEFAULT_SASL_ENABLED_MECHANISMS	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SaslConfigs.DEFAULT_SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SaslConfigs.SASL_ENABLED_MECHANISMS	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SaslConfigs.SASL_ENABLED_MECHANISMS_DOC	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SaslConfigs.SASL_KERBEROS_PRINCIPAL_TO_LOCAL_RULES_DOC	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SslConfigs.DEFAULT_PRINCIPAL_BUILDER_CLASS	As of 1.0.0. This field will be removed in a future major release. In recent versions, the config is optional and there is no default.
org.apache.kafka.common.config.SslConfigs.PRINCIPAL_BUILDER_CLASS_CONFIG	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SslConfigs.PRINCIPAL_BUILDER_CLASS_DOC	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SslConfigs.SSL_CLIENT_AUTH_CONFIG	As of 1.0.0. This field will be removed in a future major release.
org.apache.kafka.common.config.SslConfigs.SSL_CLIENT_AUTH_DOC	As of 1.0.0. This field will be removed in a future major release.

Methods

Method	Description
org.apache.kafka.clients.consumer.Consumer.close(long, TimeUnit)
org.apache.kafka.clients.consumer.Consumer.pause(TopicPartition...)
org.apache.kafka.clients.consumer.Consumer.poll(long)
org.apache.kafka.clients.consumer.Consumer.resume(TopicPartition...)
org.apache.kafka.clients.consumer.Consumer.seekToBeginning(TopicPartition...)
org.apache.kafka.clients.consumer.Consumer.seekToEnd(TopicPartition...)
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.consumer.KafkaConsumer.close(long, TimeUnit)	Since 2.0. Use KafkaConsumer.close(Duration) or KafkaConsumer.close().
org.apache.kafka.clients.consumer.KafkaConsumer.pause(TopicPartition...)	use KafkaConsumer.pause(Collection) instead.
org.apache.kafka.clients.consumer.KafkaConsumer.poll(long)	Since 2.0. Use KafkaConsumer.poll(Duration), which does not block beyond the timeout awaiting partition assignment. See KIP-266 for more information.
org.apache.kafka.clients.consumer.KafkaConsumer.resume(TopicPartition...)	use KafkaConsumer.resume(Collection) instead.
org.apache.kafka.clients.consumer.KafkaConsumer.seekToBeginning(TopicPartition...)	use KafkaConsumer.subscribe(Collection, ConsumerRebalanceListener) instead.
org.apache.kafka.clients.consumer.KafkaConsumer.seekToEnd(TopicPartition...)	use KafkaConsumer.seekToEnd(Collection) instead.
org.apache.kafka.clients.consumer.MockConsumer.pause(TopicPartition...)
org.apache.kafka.clients.consumer.MockConsumer.poll(long)
org.apache.kafka.clients.consumer.MockConsumer.resume(TopicPartition...)
org.apache.kafka.clients.consumer.MockConsumer.seekToBeginning(TopicPartition...)
org.apache.kafka.clients.consumer.MockConsumer.seekToEnd(TopicPartition...)
org.apache.kafka.clients.consumer.NoOffsetForPartitionException.partition()	please use NoOffsetForPartitionException.partitions
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.common.Metric.value()	As of 1.0.0, use Metric.metricValue() instead. This will be removed in a future major release.
org.apache.kafka.common.security.auth.KafkaPrincipal.fromString(String)	As of 1.0.0. This method will be removed in a future major release.

Constructors

Constructor	Description
org.apache.kafka.clients.admin.ConfigEntry(String, String, boolean, boolean, boolean)	since 1.1.0. This constructor will be removed in a future release.
org.apache.kafka.clients.producer.RecordMetadata(TopicPartition, long, long, long, long, int, int)	As of 0.11.0. Use @RecordMetadata(TopicPartition, long, long, long, Long, int, int).
org.apache.kafka.common.acl.AclBinding(Resource, AccessControlEntry)	Since 2.0. Use AclBinding(ResourcePattern, AccessControlEntry)
org.apache.kafka.common.acl.AclBindingFilter(ResourceFilter, AccessControlEntryFilter)	Since 2.0. Use AclBindingFilter(ResourcePatternFilter, AccessControlEntryFilter)