Deprecated API

Contents

• Interfaces
• Classes
• Enum Classes
• Exception Classes
• Fields
• Methods

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