Deprecated API

Contents

• Interfaces
• Classes
• Enum Classes
• Fields
• Methods
• Constructors

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.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

Deprecated Methods

Method	Description
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.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.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<?>, Deserializer<?>, 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<?>, Deserializer<?>, 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<?>, Deserializer<?>, 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<?>, Deserializer<?>, 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.