Deprecated API

Contents

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

Terminally Deprecated Elements

Element	Description
org.apache.kafka.streams.processor.StreamPartitioner.partitions(String, K, V, int)	Since 4.4. Use StreamPartitioner.partitions(String, Object, Object, Headers, int) instead. This method is planned to 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.streams.KafkaStreams.CloseOptions
org.apache.kafka.streams.kstream.ForeachProcessor	Since 4.0 and should not be used any longer.

Deprecated Enum Classes

Enum Class	Description
org.apache.kafka.streams.errors.DeserializationExceptionHandler.DeserializationHandlerResponse
org.apache.kafka.streams.errors.ProcessingExceptionHandler.ProcessingHandlerResponse
org.apache.kafka.streams.errors.ProductionExceptionHandler.ProductionExceptionHandlerResponse
org.apache.kafka.streams.Topology.AutoOffsetReset	Since 4.0. Use AutoOffsetReset instead.

Deprecated Exception Classes

Exception Class	Description
org.apache.kafka.streams.errors.BrokerNotFoundException	since 4.2 and should not be used any longer.

Deprecated Fields

Field	Description
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.InternalConfig.TOPIC_PREFIX_ALTERNATIVE
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.PROCESSING_EXCEPTION_HANDLER_GLOBAL_ENABLED_CONFIG	Since 4.3. Default will change to true when removed.
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.streams.errors.DeserializationExceptionHandler.handle(ErrorHandlerContext, ConsumerRecord<byte[], byte[]>, Exception)	Use DeserializationExceptionHandler.handleError(ErrorHandlerContext, ConsumerRecord, 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.ProcessingExceptionHandler.handle(ErrorHandlerContext, Record<?, ?>, Exception)	Use ProcessingExceptionHandler.handleError(ErrorHandlerContext, Record, 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.handle(ErrorHandlerContext, ProducerRecord<byte[], byte[]>, Exception)	Use ProductionExceptionHandler.handleError(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.errors.ProductionExceptionHandler.handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, ProductionExceptionHandler.SerializationExceptionOrigin)	Use ProductionExceptionHandler.handleSerializationError(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin) instead.
org.apache.kafka.streams.KafkaStreams.close(KafkaStreams.CloseOptions)
org.apache.kafka.streams.KafkaStreams.CloseOptions.leaveGroup(boolean)
org.apache.kafka.streams.KafkaStreams.CloseOptions.timeout(Duration)
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.kstream.KStream.join(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<? super K, ? super V, ? extends GlobalKey>, ValueJoinerWithKey<? super K, ? super V, ? super GlobalValue, ? extends VOut>)	Since 4.4. Use KStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey) instead.
org.apache.kafka.streams.kstream.KStream.join(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<? super K, ? super V, ? extends GlobalKey>, ValueJoinerWithKey<? super K, ? super V, ? super GlobalValue, ? extends VOut>, Named)	Since 4.4. Use KStream.join(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey, Named) instead.
org.apache.kafka.streams.kstream.KStream.leftJoin(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<? super K, ? super V, ? extends GlobalKey>, ValueJoinerWithKey<? super K, ? super V, ? super GlobalValue, ? extends VOut>)	Since 4.4. Use KStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey) instead.
org.apache.kafka.streams.kstream.KStream.leftJoin(GlobalKTable<GlobalKey, GlobalValue>, KeyValueMapper<? super K, ? super V, ? extends GlobalKey>, ValueJoinerWithKey<? super K, ? super V, ? super GlobalValue, ? extends VOut>, Named)	Since 4.4. Use KStream.leftJoin(GlobalKTable, KeyValueMapper, ValueJoinerWithStreamAndMappedKey, Named) instead.
org.apache.kafka.streams.processor.StateStore.flush()	Use ProcessorContext#commit() instead.
org.apache.kafka.streams.processor.StateStore.managesOffsets()	New implementations should always return true and manage their own offsets. In the future, this method will be removed and it will be assumed to always return true.
org.apache.kafka.streams.processor.StreamPartitioner.partitions(String, K, V, int)	Since 4.4. Use StreamPartitioner.partitions(String, Object, Object, Headers, int) instead. This method is planned to be removed in 5.0.
org.apache.kafka.streams.state.DslKeyValueParams.isTimestamped()	Since 4.3. Use DslKeyValueParams.dslStoreFormat() instead to check the store format.
org.apache.kafka.streams.state.DslWindowParams.isTimestamped()	Since 4.3. Use DslWindowParams.dslStoreFormat() instead to check the store format.
org.apache.kafka.streams.state.StateSerdes.keyFrom(byte[])	Since 4.3. Use StateSerdes.keyFrom(byte[], Headers) instead.
org.apache.kafka.streams.state.StateSerdes.rawKey(K)	Since 4.3. Use StateSerdes.rawKey(Object, Headers) instead.
org.apache.kafka.streams.state.StateSerdes.rawValue(V)	Since 4.3. Use StateSerdes.rawValue(Object, Headers) instead.
org.apache.kafka.streams.state.StateSerdes.valueFrom(byte[])	Since 4.3. Use StateSerdes.valueFrom(byte[], Headers) 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.streams.state.DslKeyValueParams(String, boolean)	Since 4.3. Use DslKeyValueParams(String, DslStoreFormat) instead.
org.apache.kafka.streams.state.DslSessionParams(String, Duration, EmitStrategy)
org.apache.kafka.streams.state.DslWindowParams(String, Duration, Duration, boolean, EmitStrategy, boolean, boolean)	Since 4.3. Use DslWindowParams(String, Duration, Duration, boolean, EmitStrategy, boolean, DslStoreFormat) Params(String, DslStoreFormat)} instead.