Deprecated List (kafka 2.8.1 API)

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.
org.apache.kafka.streams.processor.PartitionGrouper	since 2.4 release; will be removed in 3.0.0 via KAFKA-7785

Classes
Class	Description
org.apache.kafka.clients.admin.ElectPreferredLeadersOptions	Since 2.4.0. Use `Admin.electLeaders(ElectionType, Set, ElectLeadersOptions)`.
org.apache.kafka.clients.admin.ElectPreferredLeadersResult	Since 2.4.0. Use `Admin.electLeaders(ElectionType, Set, ElectLeadersOptions)`.
org.apache.kafka.common.metrics.stats.Count	since 2.4 . Use `WindowedCount` instead
org.apache.kafka.common.metrics.stats.Rate.SampledTotal	since 2.4 Use `WindowedSum` instead.
org.apache.kafka.common.metrics.stats.Sum	since 2.4 . Use `WindowedSum` instead
org.apache.kafka.common.metrics.stats.Total	since 2.4 . Use `CumulativeSum` instead.
org.apache.kafka.common.security.auth.DefaultPrincipalBuilder	As of Kafka 1.0.0. This will be removed in a future major release.
org.apache.kafka.streams.kstream.Serialized	since 2.1. Use `Grouped` instead
org.apache.kafka.streams.processor.DefaultPartitionGrouper	since 2.4 release; will be removed in 3.0.0 via KAFKA-7785
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestamp	since 2.5. Use `UsePartitionTimeOnInvalidTimestamp` instead
org.apache.kafka.streams.test.ConsumerRecordFactory	Since 2.4 use methods of `TestInputTopic` instead
org.apache.kafka.streams.test.OutputVerifier	Since 2.4 use methods of `TestOutputTopic` and standard assertion libraries instead

Exceptions
Exceptions Description

org.apache.kafka.common.errors.NotLeaderForPartitionException
since 2.6. Use NotLeaderOrFollowerException.

Exceptions
Exceptions	Description
org.apache.kafka.common.errors.NotLeaderForPartitionException	since 2.6. Use `NotLeaderOrFollowerException`.

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.
org.apache.kafka.streams.kstream.Windows.segments
org.apache.kafka.streams.StreamsConfig.PARTITION_GROUPER_CLASS_CONFIG
org.apache.kafka.streams.StreamsConfig.RETRIES_CONFIG	since 2.7
org.apache.kafka.streams.StreamsConfig.TOPOLOGY_OPTIMIZATION	since 2.7; use `StreamsConfig.TOPOLOGY_OPTIMIZATION_CONFIG` instead

Methods
Method	Description
org.apache.kafka.clients.admin.Admin.alterConfigs(Map<ConfigResource, Config>)	Since 2.3. Use `Admin.incrementalAlterConfigs(Map)`.
org.apache.kafka.clients.admin.Admin.close(long, TimeUnit)	Since 2.2. Use `Admin.close(Duration)` or `Admin.close()`.
org.apache.kafka.clients.admin.Admin.electPreferredLeaders(Collection<TopicPartition>)	Since 2.4.0. Use `Admin.electLeaders(ElectionType, Set)`.
org.apache.kafka.clients.admin.DescribeLogDirsResult.all()	Deprecated Since Kafka 2.7. Use `DescribeLogDirsResult.allDescriptions()`.
org.apache.kafka.clients.admin.DescribeLogDirsResult.values()	Deprecated Since Kafka 2.7. Use `DescribeLogDirsResult.descriptions()`.
org.apache.kafka.clients.admin.KafkaAdminClient.alterConfigs(Map<ConfigResource, Config>, AlterConfigsOptions)
org.apache.kafka.clients.consumer.Consumer.close(long, TimeUnit)
org.apache.kafka.clients.consumer.Consumer.committed(TopicPartition)
org.apache.kafka.clients.consumer.Consumer.poll(long)
org.apache.kafka.clients.consumer.ConsumerConfig.addDeserializerToConfig(Map<String, Object>, Deserializer<?>, Deserializer<?>)	Since 2.7.0. This will be removed in a future major release.
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.committed(TopicPartition)	since 2.4 Use `KafkaConsumer.committed(Set)` 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.MockConsumer.close(long, TimeUnit)
org.apache.kafka.clients.consumer.MockConsumer.committed(TopicPartition)
org.apache.kafka.clients.consumer.MockConsumer.poll(long)
org.apache.kafka.clients.consumer.MockConsumer.setException(KafkaException)	Use `MockConsumer.setPollException(KafkaException)` instead
org.apache.kafka.clients.consumer.NoOffsetForPartitionException.partition()	please use `NoOffsetForPartitionException.partitions`
org.apache.kafka.clients.producer.Producer.close(long, TimeUnit)
org.apache.kafka.clients.producer.ProducerConfig.addSerializerToConfig(Map<String, Object>, Serializer<?>, Serializer<?>)	Since 2.7.0. This will be removed in a future major release.
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.MessageFormatter.init(Properties)	Use `MessageFormatter.configure(Map)` instead, this method is for backward compatibility with the older Formatter interface
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.metrics.KafkaMetric.value()
org.apache.kafka.common.security.auth.KafkaPrincipal.fromString(String)	As of 1.0.0. This method will be removed in a future major release.
org.apache.kafka.connect.sink.SinkTask.onPartitionsAssigned(Collection<TopicPartition>)	Use `SinkTask.open(Collection)` for partition initialization.
org.apache.kafka.connect.sink.SinkTask.onPartitionsRevoked(Collection<TopicPartition>)	Use `SinkTask.close(Collection)` instead for partition cleanup.
org.apache.kafka.connect.source.SourceTask.commitRecord(SourceRecord)	Use `SourceTask.commitRecord(SourceRecord, RecordMetadata)` instead.
org.apache.kafka.streams.KafkaClientSupplier.getAdminClient(Map<String, Object>)	Not called by Kafka Streams, which now uses `KafkaClientSupplier.getAdmin(java.util.Map<java.lang.String, java.lang.Object>)` instead.
org.apache.kafka.streams.KafkaStreams.close(long, TimeUnit)	Use `KafkaStreams.close(Duration)` instead; note, that `KafkaStreams.close(Duration)` has different semantics and does not block on zero, e.g., `Duration.ofMillis(0)`.
org.apache.kafka.streams.KafkaStreams.metadataForKey(String, K, Serializer<K>)	Since 2.5. Use `KafkaStreams.queryMetadataForKey(String, Object, Serializer)` instead.
org.apache.kafka.streams.KafkaStreams.setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler)	Since 2.8.0. Use `KafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)` instead.
org.apache.kafka.streams.KafkaStreams.store(String, QueryableStoreType<T>)	since 2.5 release; use `KafkaStreams.store(StoreQueryParameters)` instead
org.apache.kafka.streams.KeyQueryMetadata.getActiveHost()	Use `KeyQueryMetadata.activeHost()` instead.
org.apache.kafka.streams.KeyQueryMetadata.getPartition()	Use `KeyQueryMetadata.partition()` instead.
org.apache.kafka.streams.KeyQueryMetadata.getStandbyHosts()	Use `KeyQueryMetadata.standbyHosts()` instead.
org.apache.kafka.streams.kstream.Joined.name()	this method will be removed in a in a future release
org.apache.kafka.streams.kstream.Joined.named(String)	use `Joined.as(String)` instead
org.apache.kafka.streams.kstream.JoinWindows.after(long)	Use `JoinWindows.after(Duration)` instead
org.apache.kafka.streams.kstream.JoinWindows.before(long)	Use `JoinWindows.before(Duration)` instead.
org.apache.kafka.streams.kstream.JoinWindows.maintainMs()	since 2.1. This function should not be used anymore, since `JoinWindows.until(long)` is deprecated in favor of `JoinWindows.grace(Duration)`.
org.apache.kafka.streams.kstream.JoinWindows.of(long)	Use `JoinWindows.of(Duration)` instead.
org.apache.kafka.streams.kstream.JoinWindows.until(long)	since 2.1. Use `JoinWindows.grace(Duration)` instead.
org.apache.kafka.streams.kstream.KStream.branch(Predicate<? super K, ? super V>...)	since 2.8. Use `KStream.split()` instead.
org.apache.kafka.streams.kstream.KStream.groupBy(KeyValueMapper<? super K, ? super V, KR>, Serialized<KR, V>)	since 2.1. Use `KStream.groupBy(KeyValueMapper, Grouped)` instead
org.apache.kafka.streams.kstream.KStream.groupByKey(Serialized<K, V>)	since 2.1. Use `KStream.groupByKey(Grouped)` instead
org.apache.kafka.streams.kstream.KStream.join(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>)	since 2.4. Use `KStream.join(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.kstream.KStream.leftJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>)	since 2.4. Use `KStream.leftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.kstream.KStream.outerJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>)	since 2.4. Use `KStream.outerJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.kstream.KStream.through(String)	since 2.6; use `KStream.repartition()` instead
org.apache.kafka.streams.kstream.KTable.groupBy(KeyValueMapper<? super K, ? super V, KeyValue<KR, VR>>, Serialized<KR, VR>)	since 2.1. Use `KTable.groupBy(KeyValueMapper, Grouped)` instead
org.apache.kafka.streams.kstream.SessionWindows.maintainMs()	since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.SessionWindows.until(long)	since 2.1. Use `Materialized.retention` or directly configure the retention in a store supplier and use `Materialized.as(SessionBytesStoreSupplier)`.
org.apache.kafka.streams.kstream.SessionWindows.with(long)	Use `SessionWindows.with(Duration)` instead.
org.apache.kafka.streams.kstream.TimeWindows.advanceBy(long)	Use `TimeWindows.advanceBy(Duration)` instead
org.apache.kafka.streams.kstream.TimeWindows.maintainMs()	since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.TimeWindows.of(long)	Use `TimeWindows.of(Duration)` instead
org.apache.kafka.streams.kstream.TimeWindows.until(long)	since 2.1. Use `Materialized.retention` or directly configure the retention in a store supplier and use `Materialized.as(WindowBytesStoreSupplier)`.
org.apache.kafka.streams.kstream.UnlimitedWindows.maintainMs()	since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.UnlimitedWindows.startOn(long)	Use `UnlimitedWindows.startOn(Instant)` instead
org.apache.kafka.streams.kstream.UnlimitedWindows.until(long)	since 2.1.
org.apache.kafka.streams.kstream.WindowedSerdes.timeWindowedSerdeFrom(Class<T>)
org.apache.kafka.streams.kstream.Windows.maintainMs()	since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.Windows.segments(int)	since 2.1 Override segmentInterval() instead.
org.apache.kafka.streams.kstream.Windows.until(long)	since 2.1. Use `Materialized.withRetention(Duration)` or directly configure the retention in a store supplier and use `Materialized.as(WindowBytesStoreSupplier)`.
org.apache.kafka.streams.processor.MockProcessorContext.forward(K, V, int)
org.apache.kafka.streams.processor.MockProcessorContext.schedule(long, PunctuationType, Punctuator)
org.apache.kafka.streams.processor.ProcessorContext.forward(K, V, int)	please use `ProcessorContext.forward(Object, Object, To)` instead
org.apache.kafka.streams.processor.ProcessorContext.schedule(long, PunctuationType, Punctuator)	Use `ProcessorContext.schedule(Duration, PunctuationType, Punctuator)` instead
org.apache.kafka.streams.processor.StateStore.init(ProcessorContext, StateStore)	Since 2.7.0. Callers should invoke `StateStore.init(StateStoreContext, StateStore)` instead. Implementers may choose to implement this method for backward compatibility or to throw an informative exception instead.
org.apache.kafka.streams.state.ReadOnlyWindowStore.fetch(K, long, long)	Use `ReadOnlyWindowStore.fetch(Object, Instant, Instant)` instead
org.apache.kafka.streams.state.ReadOnlyWindowStore.fetchAll(long, long)	Use `ReadOnlyWindowStore.fetchAll(Instant, Instant)` instead
org.apache.kafka.streams.state.Stores.persistentSessionStore(String, long)	since 2.1 Use `Stores.persistentSessionStore(String, Duration)` instead
org.apache.kafka.streams.state.Stores.persistentWindowStore(String, long, int, long, boolean)	since 2.1 Use `Stores.persistentWindowStore(String, Duration, Duration, boolean)` instead
org.apache.kafka.streams.state.WindowBytesStoreSupplier.segments()	since 2.1. Use `WindowBytesStoreSupplier.segmentIntervalMs()` instead.
org.apache.kafka.streams.state.WindowStore.put(K, V)	as timestamp is not provided for the key-value pair, this causes inconsistency to identify the window frame to which the key belongs. Use `WindowStore.put(Object, Object, long)` instead.
org.apache.kafka.streams.StreamsBuilder.addGlobalStore(StoreBuilder<?>, String, String, Consumed<K, V>, String, ProcessorSupplier<K, V>)	Use `StreamsBuilder.addGlobalStore(StoreBuilder, String, Consumed, ProcessorSupplier)` instead.
org.apache.kafka.streams.StreamsConfig.getConsumerConfigs(String, String)	use `StreamsConfig.getMainConsumerConfigs(String, String, int)`
org.apache.kafka.streams.StreamsMetrics.addLatencyAndThroughputSensor(String, String, String, Sensor.RecordingLevel, String...)	since 2.5. Use `addLatencyRateTotalSensor()` instead.
org.apache.kafka.streams.StreamsMetrics.addThroughputSensor(String, String, String, Sensor.RecordingLevel, String...)	since 2.5. Use `addRateTotalSensor()` instead.
org.apache.kafka.streams.StreamsMetrics.recordLatency(Sensor, long, long)	since 2.5. Use `Sensor#record()` instead.
org.apache.kafka.streams.StreamsMetrics.recordThroughput(Sensor, long)	since 2.5. Use `Sensor#record()` instead.
org.apache.kafka.streams.Topology.addGlobalStore(StoreBuilder<?>, String, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V>)	Since 2.7.0. Use `Topology.addGlobalStore(StoreBuilder, String, Deserializer, Deserializer, String, String, ProcessorSupplier)` instead.
org.apache.kafka.streams.Topology.addProcessor(String, ProcessorSupplier, String...)	Since 2.7.0 Use `Topology.addProcessor(String, ProcessorSupplier, String...)` instead.
org.apache.kafka.streams.TopologyDescription.Source.topics()	use `TopologyDescription.Source.topicSet()` or `TopologyDescription.Source.topicPattern()` instead
org.apache.kafka.streams.TopologyTestDriver.advanceWallClockTime(long)	Since 2.4 use `TopologyTestDriver.advanceWallClockTime(Duration)` instead
org.apache.kafka.streams.TopologyTestDriver.pipeInput(ConsumerRecord<byte[], byte[]>)	Since 2.4 use methods of `TestInputTopic` instead
org.apache.kafka.streams.TopologyTestDriver.readOutput(String)	Since 2.4 use methods of `TestOutputTopic` instead

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.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)`
org.apache.kafka.common.metrics.JmxReporter(String)	Since 2.6.0. Use `JmxReporter()` Initialize JmxReporter with `JmxReporter.contextChange(MetricsContext)` Populate prefix by adding _namespace/prefix key value pair to `MetricsContext`
org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig)	use `KafkaStreams(Topology, Properties)` instead
org.apache.kafka.streams.kstream.TimeWindowedDeserializer(Deserializer<T>)
org.apache.kafka.streams.kstream.WindowedSerdes.TimeWindowedSerde(Serde<T>)
org.apache.kafka.streams.TopologyTestDriver(Topology, Properties, long)	Since 2.4 use `TopologyTestDriver(Topology, Properties, Instant)`

Deprecated API

Contents