Deprecated API

Contents

• Deprecated Interfaces
• Deprecated Classes
• Deprecated Fields
• Deprecated Methods
• Deprecated Constructors

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.

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.DEFAULT_WINDOWED_KEY_SERDE_INNER_CLASS
org.apache.kafka.streams.StreamsConfig.DEFAULT_WINDOWED_VALUE_SERDE_INNER_CLASS
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.processor.TaskId.partition
org.apache.kafka.streams.StreamsConfig.RETRIES_CONFIG since 2.7
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.KeyQueryMetadata.getActiveHost() Use KeyQueryMetadata.activeHost() instead.
org.apache.kafka.streams.KeyQueryMetadata.getPartition() Use KeyQueryMetadata.partition() instead.
org.apache.kafka.streams.KeyQueryMetadata.getStandbyHosts() Use KeyQueryMetadata.standbyHosts() instead.
org.apache.kafka.streams.kstream.JoinWindows.grace(Duration) since 3.0. Use JoinWindows.ofTimeDifferenceAndGrace(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.TimeWindows.grace(Duration) since 3.0. Use TimeWindows.ofSizeAndGrace(Duration, Duration) 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.JoinWindows.of(Duration) since 3.0. Use JoinWindows.ofTimeDifferenceWithNoGrace(Duration)} instead
org.apache.kafka.streams.kstream.TimeWindows.of(Duration) since 3.0. Use TimeWindows.ofSizeWithNoGrace(Duration) } instead
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.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>)