Deprecated List (streams 7.9.5-ce API)

Deprecated Interfaces
Interface and Description
org.apache.kafka.streams.processor.Processor Since 3.0. Use `Processor` instead.
org.apache.kafka.streams.processor.ProcessorSupplier Since 3.0. Use `ProcessorSupplier` instead.
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 and Description
org.apache.kafka.streams.processor.AbstractProcessor Since 3.0. Use `Processor` or `ContextualProcessor` instead.
org.apache.kafka.streams.state.StreamsMetadata since 3.0.0 use `StreamsMetadata`
org.apache.kafka.streams.processor.TaskMetadata since 3.0, use `TaskMetadata` instead.
org.apache.kafka.streams.processor.ThreadMetadata since 3.0 use `ThreadMetadata` instead

Deprecated Fields
Field and Description
org.apache.kafka.streams.StreamsConfig.AUTO_INCLUDE_JMX_REPORTER_CONFIG and will be removed in 4.0.0
org.apache.kafka.streams.StreamsConfig.CACHE_MAX_BYTES_BUFFERING_CONFIG since 3.4.0 Use `"statestore.cache.max.bytes"` instead.
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_CONFIG
org.apache.kafka.streams.StreamsConfig.DEFAULT_DSL_STORE_DOC
org.apache.kafka.streams.StreamsConfig.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS since 3.0.0 Use `"windowed.inner.class.serde"` instead.
org.apache.kafka.streams.StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS since 3.0.0 Use `"windowed.inner.class.serde"` instead.
org.apache.kafka.streams.StreamsConfig.EXACTLY_ONCE since 3.0.0, will be removed in 4.0. Use `"exactly_once_v2"` instead.
org.apache.kafka.streams.StreamsConfig.EXACTLY_ONCE_BETA since 3.0.0, will be removed in 4.0. Use `"exactly_once_v2"` instead.
org.apache.kafka.streams.StreamsConfig.IN_MEMORY
org.apache.kafka.streams.processor.TaskId.partition
org.apache.kafka.streams.StreamsConfig.RETRIES_CONFIG since 2.7
org.apache.kafka.streams.StreamsConfig.ROCKS_DB
org.apache.kafka.streams.processor.TaskId.topicGroupId
org.apache.kafka.streams.StreamsConfig.TOPOLOGY_OPTIMIZATION since 2.7; use `StreamsConfig.TOPOLOGY_OPTIMIZATION_CONFIG` instead

Deprecated Methods
Method and Description
org.apache.kafka.streams.StreamsBuilder.addGlobalStore(StoreBuilder<?>, String, Consumed<K, V>, ProcessorSupplier<K, V>) Since 2.7.0; use `StreamsBuilder.addGlobalStore(StoreBuilder, String, Consumed, ProcessorSupplier)` 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.addGlobalStore(StoreBuilder<?>, String, TimestampExtractor, Deserializer<K>, Deserializer<V>, String, String, ProcessorSupplier<K, V>) Since 2.7.0. Use `Topology.addGlobalStore(StoreBuilder, String, TimestampExtractor, 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.KafkaStreams.allMetadata() since 3.0.0 use `KafkaStreams.metadataForAllStreamsClients()`
org.apache.kafka.streams.KafkaStreams.allMetadataForStore(String) since 3.0.0 use `KafkaStreams.streamsMetadataForStore(java.lang.String)` instead
org.apache.kafka.streams.kstream.KStream.branch(Named, Predicate<? super K, ? super V>...) since 2.8. Use `KStream.split(Named)` 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.flatTransform(TransformerSupplier<? super K, ? super V, Iterable<KeyValue<K1, V1>>>, Named, String...) Since 3.3. Use `KStream.process(ProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.flatTransform(TransformerSupplier<? super K, ? super V, Iterable<KeyValue<K1, V1>>>, String...) Since 3.3. Use `KStream.process(ProcessorSupplier, String...)` instead.
org.apache.kafka.streams.kstream.KStream.flatTransformValues(ValueTransformerSupplier<? super V, Iterable<VR>>, Named, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.flatTransformValues(ValueTransformerSupplier<? super V, Iterable<VR>>, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, String...)` instead.
org.apache.kafka.streams.kstream.KStream.flatTransformValues(ValueTransformerWithKeySupplier<? super K, ? super V, Iterable<VR>>, Named, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.flatTransformValues(ValueTransformerWithKeySupplier<? super K, ? super V, Iterable<VR>>, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, String...)` instead.
org.apache.kafka.streams.KeyQueryMetadata.getActiveHost() since 2.7.0; use `KeyQueryMetadata.activeHost()` instead.
org.apache.kafka.streams.KeyQueryMetadata.getPartition() since 2.7.0; use `KeyQueryMetadata.partition()` instead.
org.apache.kafka.streams.KeyQueryMetadata.getStandbyHosts() since 2.7.0; use `KeyQueryMetadata.standbyHosts()` instead.
org.apache.kafka.streams.kstream.TimeWindows.grace(Duration) since 3.0. Use `TimeWindows.ofSizeAndGrace(Duration, Duration)` instead
org.apache.kafka.streams.kstream.SessionWindows.grace(Duration) since 3.0. Use `SessionWindows.ofInactivityGapAndGrace(Duration, Duration)` instead
org.apache.kafka.streams.kstream.JoinWindows.grace(Duration) since 3.0. Use `JoinWindows.ofTimeDifferenceAndGrace(Duration, Duration)` instead
org.apache.kafka.streams.errors.LogAndFailExceptionHandler.handle(ProcessorContext, ConsumerRecord<byte[], byte[]>, Exception)
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)
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.DefaultProductionExceptionHandler.handle(ProducerRecord<byte[], byte[]>, Exception)
org.apache.kafka.streams.errors.ProductionExceptionHandler.handleSerializationException(ProducerRecord, Exception) Since 3.9. Use `ProductionExceptionHandler.handleSerializationException(ErrorHandlerContext, ProducerRecord, Exception, SerializationExceptionOrigin)` 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.kstream.KTable.join(KTable<KO, VO>, Function<V, KO>, ValueJoiner<V, VO, VR>, Named) since 3.1, removal planned for 4.0. Use `KTable.join(KTable, Function, ValueJoiner, TableJoined)` instead.
org.apache.kafka.streams.kstream.KTable.join(KTable<KO, VO>, Function<V, KO>, ValueJoiner<V, VO, VR>, Named, Materialized<K, VR, KeyValueStore<Bytes, byte[]>>) since 3.1, removal planned for 4.0. Use `KTable.join(KTable, Function, ValueJoiner, TableJoined, Materialized)` instead.
org.apache.kafka.streams.kstream.KTable.leftJoin(KTable<KO, VO>, Function<V, KO>, ValueJoiner<V, VO, VR>, Named) since 3.1, removal planned for 4.0. Use `KTable.leftJoin(KTable, Function, ValueJoiner, TableJoined)` instead.
org.apache.kafka.streams.kstream.KTable.leftJoin(KTable<KO, VO>, Function<V, KO>, ValueJoiner<V, VO, VR>, Named, Materialized<K, VR, KeyValueStore<Bytes, byte[]>>) since 3.1, removal planned for 4.0. Use `KTable.leftJoin(KTable, Function, ValueJoiner, TableJoined, Materialized)` instead.
org.apache.kafka.streams.KafkaStreams.localThreadsMetadata() since 3.0 use `KafkaStreams.metadataForLocalThreads()`
org.apache.kafka.streams.kstream.TimeWindows.of(Duration) since 3.0. Use `TimeWindows.ofSizeWithNoGrace(Duration)` } instead
org.apache.kafka.streams.kstream.JoinWindows.of(Duration) since 3.0. Use `JoinWindows.ofTimeDifferenceWithNoGrace(Duration)`} instead
org.apache.kafka.streams.TopologyConfig.parseStoreType()
org.apache.kafka.streams.processor.StreamPartitioner.partition(String, K, V, int)
org.apache.kafka.streams.kstream.KStream.process(ProcessorSupplier<? super K, ? super V>, Named, String...) Since 3.0. Use `KStream.process(org.apache.kafka.streams.processor.api.ProcessorSupplier, org.apache.kafka.streams.kstream.Named, java.lang.String...)` instead.
org.apache.kafka.streams.kstream.KStream.process(ProcessorSupplier<? super K, ? super V>, String...) Since 3.0. Use `KStream.process(org.apache.kafka.streams.processor.api.ProcessorSupplier, java.lang.String...)` instead.
org.apache.kafka.streams.processor.TaskId.readFrom(ByteBuffer, int) since 3.0, for internal use, will be removed
org.apache.kafka.streams.processor.TaskId.readFrom(DataInputStream, int) since 3.0, for internal use, will be removed
org.apache.kafka.streams.KafkaStreams.setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler) Since 2.8.0. Use `KafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)` instead.
org.apache.kafka.streams.kstream.KStream.through(String) since 2.6; use `KStream.repartition()` instead
org.apache.kafka.streams.kstream.KStream.through(String, Produced<K, V>) since 2.6; use `KStream.repartition(Repartitioned)` instead
org.apache.kafka.streams.kstream.WindowedSerdes.timeWindowedSerdeFrom(Class<T>)
org.apache.kafka.streams.kstream.KStream.transform(TransformerSupplier<? super K, ? super V, KeyValue<K1, V1>>, Named, String...) Since 3.3. Use `KStream.process(ProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.transform(TransformerSupplier<? super K, ? super V, KeyValue<K1, V1>>, String...) Since 3.3. Use `KStream.process(ProcessorSupplier, String...)` instead.
org.apache.kafka.streams.kstream.KStream.transformValues(ValueTransformerSupplier<? super V, ? extends VR>, Named, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.transformValues(ValueTransformerSupplier<? super V, ? extends VR>, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, String...)` instead.
org.apache.kafka.streams.kstream.KStream.transformValues(ValueTransformerWithKeySupplier<? super K, ? super V, ? extends VR>, Named, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, Named, String...)` instead.
org.apache.kafka.streams.kstream.KStream.transformValues(ValueTransformerWithKeySupplier<? super K, ? super V, ? extends VR>, String...) Since 3.3. Use `KStream.processValues(FixedKeyProcessorSupplier, String...)` instead.
org.apache.kafka.streams.kstream.SessionWindows.with(Duration) since 3.0. Use `SessionWindows.ofInactivityGapWithNoGrace(Duration)` instead
org.apache.kafka.streams.kstream.SlidingWindows.withTimeDifferenceAndGrace(Duration, Duration) since 3.0. Use `SlidingWindows.ofTimeDifferenceWithNoGrace(Duration)` or `SlidingWindows.ofTimeDifferenceAndGrace(Duration, Duration)` instead
org.apache.kafka.streams.processor.TaskId.writeTo(ByteBuffer, int) since 3.0, for internal use, will be removed
org.apache.kafka.streams.processor.TaskId.writeTo(DataOutputStream, int) since 3.0, for internal use, will be removed

Deprecated Constructors
Constructor and Description
org.apache.kafka.streams.kstream.TimeWindowedDeserializer(Deserializer<T>)
org.apache.kafka.streams.kstream.WindowedSerdes.TimeWindowedSerde(Serde<T>)

Deprecated API

Contents