Deprecated API

Contents

• Terminally Deprecated
• Interfaces
• Classes
• Enum Classes
• Fields
• Methods
• Constructors

Terminally Deprecated Elements

Element	Description
org.apache.kafka.clients.admin.Admin.listClientMetricsResources()	Since 4.1. Use Admin.listConfigResources() instead.
org.apache.kafka.clients.admin.Admin.listClientMetricsResources(ListClientMetricsResourcesOptions)	Since 4.1. Use Admin.listConfigResources(Set, ListConfigResourcesOptions) instead.
org.apache.kafka.clients.admin.Admin.listConsumerGroups()	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.clients.admin.Admin.listConsumerGroups(ListConsumerGroupsOptions)	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.clients.admin.KafkaAdminClient.listConsumerGroups(ListConsumerGroupsOptions)
org.apache.kafka.clients.admin.RaftVoterEndpoint.name()	Since 4.1. Use RaftVoterEndpoint.listener() instead. This function will be removed in 5.0.
org.apache.kafka.common.Endpoint.listenerName()	Since 4.1. Use Endpoint.listener() instead. This function will be removed in 5.0.

Deprecated Interfaces

Interface	Description
org.apache.kafka.streams.kstream.Transformer	Since 4.0. Use api.Processor instead.
org.apache.kafka.streams.kstream.TransformerSupplier	Since 4.0. Use api.ProcessorSupplier instead.
org.apache.kafka.streams.kstream.ValueTransformer	Since 4.0. Use FixedKeyProcessor instead.
org.apache.kafka.streams.kstream.ValueTransformerSupplier	Since 4.0. Use FixedKeyProcessorSupplier instead.

Deprecated Classes

Class	Description
org.apache.kafka.clients.admin.ClientMetricsResourceListing
org.apache.kafka.clients.admin.ConsumerGroupListing	Since 4.1. Use Admin.listGroups(ListGroupsOptions) and GroupListing instead.
org.apache.kafka.clients.admin.ListClientMetricsResourcesOptions	Since 4.1. Use ListConfigResourcesOptions instead.
org.apache.kafka.clients.admin.ListClientMetricsResourcesResult	Since 4.1. Use ListConfigResourcesResult instead.
org.apache.kafka.clients.admin.ListConsumerGroupsOptions	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.clients.admin.ListConsumerGroupsResult	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.streams.kstream.ForeachProcessor	Since 4.0 and should not be used any longer.
org.apache.kafka.streams.processor.MockProcessorContext	Since 4.0. Use MockProcessorContext instead.

Deprecated Enum Classes

Enum Class	Description
org.apache.kafka.clients.consumer.OffsetResetStrategy	Since 4.0. Use AutoOffsetResetStrategy instead.
org.apache.kafka.common.ConsumerGroupState	Since 4.0. Use GroupState instead.
org.apache.kafka.streams.Topology.AutoOffsetReset	Since 4.0. Use AutoOffsetReset instead.

Deprecated Fields

Field	Description
org.apache.kafka.common.config.TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_CONFIG	down-conversion is not possible in Apache Kafka 4.0 and newer, hence this configuration is a no-op, and it is deprecated for removal in Apache Kafka 5.0.
org.apache.kafka.common.config.TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_DOC	see TopicConfig.MESSAGE_DOWNCONVERSION_ENABLE_CONFIG.
org.apache.kafka.streams.StreamsConfig.BUFFERED_RECORDS_PER_PARTITION_DOC
org.apache.kafka.streams.StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG	Since 3.4. Use "statestore.cache.max.bytes" instead.
org.apache.kafka.streams.StreamsConfig.CACHE_MAX_BYTES_BUFFERING_DOC
org.apache.kafka.streams.StreamsConfig.DEFAULT_CLIENT_SUPPLIER_DOC
org.apache.kafka.streams.StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG	Since 4.0. Use StreamsConfig.DESERIALIZATION_EXCEPTION_HANDLER_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.DEFAULT_DESERIALIZATION_EXCEPTION_HANDLER_CLASS_DOC
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_CONFIG	Since 3.7. Use StreamsConfig.DSL_STORE_SUPPLIERS_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_DOC
org.apache.kafka.streams.StreamsConfig.DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG	Since 4.0. Use StreamsConfig.PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG instead.
org.apache.kafka.streams.StreamsConfig.DEFAULT_TIMESTAMP_EXTRACTOR_CLASS_DOC
org.apache.kafka.streams.StreamsConfig.DUMMY_THREAD_INDEX
org.apache.kafka.streams.StreamsConfig.ENABLE_METRICS_PUSH_DOC
org.apache.kafka.streams.StreamsConfig.IN_MEMORY
org.apache.kafka.streams.StreamsConfig.MAX_TASK_IDLE_MS_DOC
org.apache.kafka.streams.StreamsConfig.PROCESSING_EXCEPTION_HANDLER_CLASS_DOC
org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_DOC
org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_DOC
org.apache.kafka.streams.StreamsConfig.RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_DOC
org.apache.kafka.streams.StreamsConfig.ROCKS_DB
org.apache.kafka.streams.StreamsConfig.STATESTORE_CACHE_MAX_BYTES_DOC
org.apache.kafka.streams.StreamsConfig.TASK_TIMEOUT_MS_DOC
org.apache.kafka.streams.StreamsConfig.WINDOW_SIZE_MS_CONFIG	since 4.1.0. Use TimeWindowedDeserializer.WINDOW_SIZE_MS_CONFIG for TimeWindowedDeserializer.
org.apache.kafka.streams.StreamsConfig.WINDOWED_INNER_CLASS_SERDE	since 4.1.0. Use TimeWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASS for TimeWindowedSerializer. Use TimeWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASS for TimeWindowedDeserializer. Use SessionWindowedSerializer.WINDOWED_INNER_SERIALIZER_CLASS for SessionWindowedSerializer. Use SessionWindowedDeserializer.WINDOWED_INNER_DESERIALIZER_CLASS for SessionWindowedDeserializer.

Deprecated Methods

Method	Description
org.apache.kafka.clients.admin.Admin.listClientMetricsResources()	Since 4.1. Use Admin.listConfigResources() instead.
org.apache.kafka.clients.admin.Admin.listClientMetricsResources(ListClientMetricsResourcesOptions)	Since 4.1. Use Admin.listConfigResources(Set, ListConfigResourcesOptions) instead.
org.apache.kafka.clients.admin.Admin.listConsumerGroups()	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.clients.admin.Admin.listConsumerGroups(ListConsumerGroupsOptions)	Since 4.1. Use Admin.listGroups(ListGroupsOptions) instead.
org.apache.kafka.clients.admin.ConsumerGroupDescription.state()	Since 4.0. Use ConsumerGroupDescription.groupState() instead.
org.apache.kafka.clients.admin.ConsumerGroupListing.state()	Since 4.0. Use ConsumerGroupListing.groupState() instead.
org.apache.kafka.clients.admin.CreateDelegationTokenOptions.maxlifeTimeMs()	Since 4.0 and should not be used any longer.
org.apache.kafka.clients.admin.CreateDelegationTokenOptions.maxlifeTimeMs(long)	Since 4.0 and should not be used any longer.
org.apache.kafka.clients.admin.ForwardingAdmin.listConsumerGroups(ListConsumerGroupsOptions)
org.apache.kafka.clients.admin.KafkaAdminClient.listConsumerGroups(ListConsumerGroupsOptions)
org.apache.kafka.clients.admin.ListConsumerGroupsOptions.inStates(Set<ConsumerGroupState>)	Since 4.0. Use ListConsumerGroupsOptions.inGroupStates(Set) instead.
org.apache.kafka.clients.admin.ListConsumerGroupsOptions.states()	Since 4.0. Use ListConsumerGroupsOptions.inGroupStates(Set) instead.
org.apache.kafka.clients.admin.RaftVoterEndpoint.name()	Since 4.1. Use RaftVoterEndpoint.listener() instead. This function will be removed in 5.0.
org.apache.kafka.clients.consumer.Consumer.close(Duration)
org.apache.kafka.clients.consumer.KafkaConsumer.close(Duration)
org.apache.kafka.clients.consumer.MockConsumer.close(Duration)
org.apache.kafka.common.Endpoint.listenerName()	Since 4.1. Use Endpoint.listener() instead. This function will be removed in 5.0.
org.apache.kafka.streams.errors.DefaultProductionExceptionHandler.handle(ProducerRecord<byte[], byte[]>, Exception)	Since 3.9. Use DefaultProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord, Exception) instead.
org.apache.kafka.streams.errors.DeserializationExceptionHandler.handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)	Since 3.9. Use DeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception) instead.
org.apache.kafka.streams.errors.LogAndContinueExceptionHandler.handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)	Since 3.9. Use LogAndContinueExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception) instead.
org.apache.kafka.streams.errors.LogAndFailExceptionHandler.handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)	Since 3.9. Use LogAndFailExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord, Exception) instead.
org.apache.kafka.streams.errors.ProductionExceptionHandler.handle(ProducerRecord<byte[], byte[]>, Exception)	Since 3.9. Use ProductionExceptionHandler.handle(ErrorHandlerContext, ProducerRecord, Exception) instead.
org.apache.kafka.streams.errors.ProductionExceptionHandler.handleSerializationException(ProducerRecord, Exception)	Since 3.9. Use ProductionExceptionHandler.handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin) instead.
org.apache.kafka.streams.kstream.Consumed.with(Serde<K>, Serde<V>, TimestampExtractor, Topology.AutoOffsetReset)	Since 4.0. Use Consumed.with(Serde, Serde, TimestampExtractor, AutoOffsetReset) instead.
org.apache.kafka.streams.kstream.Consumed.with(Topology.AutoOffsetReset)	Since 4.0. Use Consumed.with(AutoOffsetReset) instead.
org.apache.kafka.streams.kstream.Consumed.withOffsetResetPolicy(Topology.AutoOffsetReset)	Since 4.0. Use Consumed.withOffsetResetPolicy(AutoOffsetReset) instead.
org.apache.kafka.streams.kstream.Joined.gracePeriod()	Since 4.0 and should not be used any longer.
org.apache.kafka.streams.kstream.Joined.keySerde()	Since 4.0 and should not be used any longer.
org.apache.kafka.streams.kstream.Joined.otherValueSerde()	Since 4.0 and should not be used any longer.
org.apache.kafka.streams.kstream.Joined.valueSerde()	Since 4.0 and should not be used any longer.
org.apache.kafka.streams.kstream.JoinWindows.grace(Duration)	Since 3.0. Use JoinWindows.ofTimeDifferenceAndGrace(Duration, Duration) instead.
org.apache.kafka.streams.kstream.JoinWindows.of(Duration)	Since 3.0. Use JoinWindows.ofTimeDifferenceWithNoGrace(Duration)} instead.
org.apache.kafka.streams.StreamsConfig.defaultDeserializationExceptionHandler()	Since 4.0. Use StreamsConfig.deserializationExceptionHandler() instead.
org.apache.kafka.streams.StreamsConfig.defaultProductionExceptionHandler()	Since 4.0. Use StreamsConfig.productionExceptionHandler() instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, String...)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, String...) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Pattern)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Pattern) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Deserializer<K>, Deserializer<V>, String...)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Deserializer, Deserializer, String...) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, Deserializer<K>, Deserializer<V>, Pattern)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, Deserializer, Deserializer, Pattern) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String...)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, String...) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, Pattern)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, String, TimestampExtractor, Deserializer, Deserializer, Pattern) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, TimestampExtractor, String, String...)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, TimestampExtractor, String, String...) instead.
org.apache.kafka.streams.Topology.addSource(Topology.AutoOffsetReset, TimestampExtractor, String, Pattern)	Since 4.0. Use Topology.addSource(org.apache.kafka.streams.AutoOffsetReset, TimestampExtractor, String, Pattern) instead.
org.apache.kafka.streams.TopologyConfig.parseStoreType()

Deprecated Constructors

Constructor	Description
org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node)	Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, ConsumerGroupState, Node, Set<AclOperation>)	Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
org.apache.kafka.clients.admin.ConsumerGroupDescription(String, boolean, Collection<MemberDescription>, String, GroupType, ConsumerGroupState, Node, Set<AclOperation>)	Since 4.0. Use ConsumerGroupDescription(String, boolean, Collection, String, GroupType, GroupState, Node, Set, Optional, Optional) instead.
org.apache.kafka.clients.admin.ConsumerGroupListing(String, boolean, Optional<ConsumerGroupState>)	Since 4.0. Use ConsumerGroupListing(String, Optional, boolean) instead.
org.apache.kafka.clients.admin.ConsumerGroupListing(String, boolean, Optional<ConsumerGroupState>, Optional<GroupType>)	Since 4.0. Use ConsumerGroupListing(String, Optional, Optional, boolean) instead.
org.apache.kafka.clients.admin.MemberDescription(String, String, String, MemberAssignment)	Since 4.0. Use MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment)	Since 4.0. Use MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
org.apache.kafka.clients.admin.MemberDescription(String, Optional<String>, String, String, MemberAssignment, Optional<MemberAssignment>)	Since 4.0. Use MemberDescription(String, Optional, String, String, MemberAssignment, Optional, Optional, Optional) instead.
org.apache.kafka.clients.consumer.ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>)	Since 4.0. Use ConsumerRecords(Map, Map) instead.
org.apache.kafka.clients.consumer.MockConsumer(OffsetResetStrategy)	Since 4.0. Use MockConsumer(String) instead.
org.apache.kafka.common.errors.RecordDeserializationException(TopicPartition, long, String, Throwable)	Since 3.9. Use RecordDeserializationException(DeserializationExceptionOrigin, TopicPartition, long, long, TimestampType, ByteBuffer, ByteBuffer, Headers, String, Throwable) instead.