Deprecated List (streams 6.1.8-ce API)

Deprecated Interfaces
Interface and Description

org.apache.kafka.streams.processor.PartitionGrouper
since 2.4 release; will be removed in 3.0.0 via KAFKA-7785

Deprecated Interfaces
Interface and Description
org.apache.kafka.streams.processor.PartitionGrouper since 2.4 release; will be removed in 3.0.0 via KAFKA-7785

Deprecated Classes
Class and Description
org.apache.kafka.streams.processor.DefaultPartitionGrouper since 2.4 release; will be removed in 3.0.0 via KAFKA-7785
org.apache.kafka.streams.kstream.Serialized since 2.1. Use `Grouped` instead
org.apache.kafka.streams.processor.UsePreviousTimeOnInvalidTimestamp since 2.5. Use `UsePartitionTimeOnInvalidTimestamp` instead

Deprecated Fields
Field and Description
org.apache.kafka.streams.StreamsConfig.PARTITION_GROUPER_CLASS_CONFIG
org.apache.kafka.streams.StreamsConfig.RETRIES_CONFIG since 2.7
org.apache.kafka.streams.kstream.Windows.segments
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.StreamsBuilder.addGlobalStore(StoreBuilder<?>, String, String, Consumed<K, V>, String, ProcessorSupplier<K, V>) Use `StreamsBuilder.addGlobalStore(StoreBuilder, String, Consumed, 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.StreamsMetrics.addLatencyAndThroughputSensor(String, String, String, Sensor.RecordingLevel, String...) since 2.5. Use `addLatencyRateTotalSensor()` 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.StreamsMetrics.addThroughputSensor(String, String, String, Sensor.RecordingLevel, String...) since 2.5. Use `addRateTotalSensor()` instead.
org.apache.kafka.streams.kstream.TimeWindows.advanceBy(long) Use `TimeWindows.advanceBy(Duration)` instead
org.apache.kafka.streams.kstream.JoinWindows.after(long) Use `JoinWindows.after(Duration)` instead
org.apache.kafka.streams.kstream.JoinWindows.before(long) Use `JoinWindows.before(Duration)` instead.
org.apache.kafka.streams.KafkaStreams.close(long, TimeUnit) Use `KafkaStreams.close(Duration)` instead; note, that `KafkaStreams.close(Duration)` has different semantics and does not block on zero, e.g., `Duration.ofMillis(0)`.
org.apache.kafka.streams.state.ReadOnlyWindowStore.fetch(K, K, long, long) Use `ReadOnlyWindowStore.fetch(Object, Object, Instant, Instant)` instead
org.apache.kafka.streams.state.ReadOnlyWindowStore.fetch(K, long, long) Use `ReadOnlyWindowStore.fetch(Object, Instant, Instant)` instead
org.apache.kafka.streams.state.ReadOnlyWindowStore.fetchAll(long, long) Use `ReadOnlyWindowStore.fetchAll(Instant, Instant)` instead
org.apache.kafka.streams.processor.ProcessorContext.forward(K, V, int) please use `ProcessorContext.forward(Object, Object, To)` instead
org.apache.kafka.streams.processor.ProcessorContext.forward(K, V, String) please use `ProcessorContext.forward(Object, Object, To)` instead
org.apache.kafka.streams.KeyQueryMetadata.getActiveHost() Use `KeyQueryMetadata.activeHost()` instead.
org.apache.kafka.streams.KafkaClientSupplier.getAdminClient(Map<String, Object>) Not called by Kafka Streams, which now uses `KafkaClientSupplier.getAdmin(java.util.Map<java.lang.String, java.lang.Object>)` instead.
org.apache.kafka.streams.StreamsConfig.getConsumerConfigs(String, String) use `StreamsConfig.getMainConsumerConfigs(String, String, int)`
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.KTable.groupBy(KeyValueMapper<? super K, ? super V, KeyValue<KR, VR>>, Serialized<KR, VR>) since 2.1. Use `KTable.groupBy(KeyValueMapper, Grouped)` instead
org.apache.kafka.streams.kstream.KStream.groupBy(KeyValueMapper<? super K, ? super V, KR>, Serialized<KR, V>) since 2.1. Use `KStream.groupBy(KeyValueMapper, Grouped)` instead
org.apache.kafka.streams.kstream.KStream.groupByKey(Serialized<K, V>) since 2.1. Use `KStream.groupByKey(Grouped)` 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.KStream.join(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>) since 2.4. Use `KStream.join(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.kstream.KStream.leftJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>) since 2.4. Use `KStream.leftJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.kstream.UnlimitedWindows.maintainMs() since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.Windows.maintainMs() since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.JoinWindows.maintainMs() since 2.1. This function should not be used anymore, since `JoinWindows.until(long)` is deprecated in favor of `JoinWindows.grace(Duration)`.
org.apache.kafka.streams.kstream.TimeWindows.maintainMs() since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.kstream.SessionWindows.maintainMs() since 2.1. Use `Materialized.retention` instead.
org.apache.kafka.streams.KafkaStreams.metadataForKey(String, K, Serializer<K>) Since 2.5. Use `KafkaStreams.queryMetadataForKey(String, Object, Serializer)` instead.
org.apache.kafka.streams.KafkaStreams.metadataForKey(String, K, StreamPartitioner<? super K, ?>) Since 2.5. Use `KafkaStreams.queryMetadataForKey(String, Object, StreamPartitioner)` instead.
org.apache.kafka.streams.kstream.Joined.name() this method will be removed in a in a future release
org.apache.kafka.streams.kstream.Joined.named(String) use `Joined.as(String)` instead
org.apache.kafka.streams.kstream.JoinWindows.of(long) Use `JoinWindows.of(Duration)` instead.
org.apache.kafka.streams.kstream.TimeWindows.of(long) Use `TimeWindows.of(Duration)` instead
org.apache.kafka.streams.kstream.KStream.outerJoin(KStream<K, VO>, ValueJoiner<? super V, ? super VO, ? extends VR>, JoinWindows, Joined<K, V, VO>) since 2.4. Use `KStream.outerJoin(KStream, ValueJoiner, JoinWindows, StreamJoined)` instead.
org.apache.kafka.streams.state.Stores.persistentSessionStore(String, long) since 2.1 Use `Stores.persistentSessionStore(String, Duration)` instead
org.apache.kafka.streams.state.Stores.persistentWindowStore(String, long, int, long, boolean) since 2.1 Use `Stores.persistentWindowStore(String, Duration, Duration, boolean)` instead
org.apache.kafka.streams.state.WindowStore.put(K, V) as timestamp is not provided for the key-value pair, this causes inconsistency to identify the window frame to which the key belongs. Use `WindowStore.put(Object, Object, long)` instead.
org.apache.kafka.streams.StreamsMetrics.recordLatency(Sensor, long, long) since 2.5. Use `Sensor#record()` instead.
org.apache.kafka.streams.StreamsMetrics.recordThroughput(Sensor, long) since 2.5. Use `Sensor#record()` instead.
org.apache.kafka.streams.processor.ProcessorContext.schedule(long, PunctuationType, Punctuator) Use `ProcessorContext.schedule(Duration, PunctuationType, Punctuator)` instead
org.apache.kafka.streams.state.WindowBytesStoreSupplier.segments() since 2.1. Use `WindowBytesStoreSupplier.segmentIntervalMs()` instead.
org.apache.kafka.streams.kstream.Windows.segments(int) since 2.1 Override segmentInterval() instead.
org.apache.kafka.streams.kstream.UnlimitedWindows.startOn(long) Use `UnlimitedWindows.startOn(Instant)` instead
org.apache.kafka.streams.KafkaStreams.store(String, QueryableStoreType<T>) since 2.5 release; use `KafkaStreams.store(StoreQueryParameters)` instead
org.apache.kafka.streams.kstream.KStream.through(String) since 2.6; used `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.TopologyDescription.Source.topics() use `TopologyDescription.Source.topicSet()` or `TopologyDescription.Source.topicPattern()` instead
org.apache.kafka.streams.kstream.UnlimitedWindows.until(long) since 2.1.
org.apache.kafka.streams.kstream.Windows.until(long) since 2.1. Use `Materialized.withRetention(Duration)` or directly configure the retention in a store supplier and use `Materialized.as(WindowBytesStoreSupplier)`.
org.apache.kafka.streams.kstream.JoinWindows.until(long) since 2.1. Use `JoinWindows.grace(Duration)` instead.
org.apache.kafka.streams.kstream.TimeWindows.until(long) since 2.1. Use `Materialized.retention` or directly configure the retention in a store supplier and use `Materialized.as(WindowBytesStoreSupplier)`.
org.apache.kafka.streams.kstream.SessionWindows.until(long) since 2.1. Use `Materialized.retention` or directly configure the retention in a store supplier and use `Materialized.as(SessionBytesStoreSupplier)`.
org.apache.kafka.streams.kstream.SessionWindows.with(long) Use `SessionWindows.with(Duration)` instead.

Deprecated Constructors
Constructor and Description
org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig) use `KafkaStreams(Topology, Properties)` instead
org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig, KafkaClientSupplier) use `KafkaStreams(Topology, Properties, KafkaClientSupplier)` instead
org.apache.kafka.streams.KafkaStreams(Topology, StreamsConfig, Time) use `KafkaStreams(Topology, Properties, Time)` instead

Deprecated API

Contents