[KAFKA-12829] Remove Deprecated methods can classes of old Processor API

• Type: Sub-task
• Status: Open
• Priority: Blocker
• Resolution: Unresolved
• Fix Version/s: 4.0.0
• Component/s: streams
• Assignee: Unassigned
• Reporter: Josep Prat
• Created: 21/May/21 08:14
• Updated: 04/Mar/24 22:00

Description

The following methods were deprecated in version 2.7:

• org.apache.kafka.streams.Topology#addProcessor(java.lang.String, org.apache.kafka.streams.processor.ProcessorSupplier, java.lang.String...)
• org.apache.kafka.streams.Topology#addGlobalStore(org.apache.kafka.streams.state.StoreBuilder<?>, java.lang.String, org.apache.kafka.common.serialization.Deserializer<K>, org.apache.kafka.common.serialization.Deserializer<V>, java.lang.String, java.lang.String, org.apache.kafka.streams.processor.ProcessorSupplier<K,V>)
• org.apache.kafka.streams.Topology#addGlobalStore(org.apache.kafka.streams.state.StoreBuilder<?>, java.lang.String, org.apache.kafka.streams.processor.TimestampExtractor, org.apache.kafka.common.serialization.Deserializer<K>, org.apache.kafka.common.serialization.Deserializer<V>, java.lang.String, java.lang.String, org.apache.kafka.streams.processor.ProcessorSupplier<K,V>)
• org.apache.kafka.streams.StreamsBuilder#addGlobalStore(org.apache.kafka.streams.state.StoreBuilder<?>, java.lang.String, org.apache.kafka.streams.kstream.Consumed<K,V>, org.apache.kafka.streams.processor.ProcessorSupplier<K,V>)
• org.apache.kafka.streams.processor.StateStore#init(org.apache.kafka.streams.processor.ProcessorContext, org.apache.kafka.streams.processor.StateStore)
• org.apache.kafka.streams.kstream.KStream.process (multiple, taking the old `ProcessorSupplier`)
• org.apache.kafka.streams.scala.KStream.process (multiple, taking the old `ProcessorSupplier`)

The following classes were deprecated:

• org.apache.kafka.streams.processor.{Processor, ProcessorSupplier, ProcessorContext} (note: that `ProcessorContext` is also use by `Transformer` which was also deprecated in 3.3 and can be removed, too)
• Cf https://issues.apache.org/jira/browse/KAFKA-16339 – both tickets should be worked on together

Also cf related tickets:

• https://issues.apache.org/jira/browse/KAFKA-12832
• https://issues.apache.org/jira/browse/KAFKA-12833

See KAFKA-10605 and KIP-478.

Issue Links

• contains: KAFKA-12825 Remove Deprecated method StreamsBuilder#addGlobalStore
• contains: KAFKA-12831 Remove Deprecated method StateStore#init