Deprecated API

Contents

• Methods

Methods

Method	Description
brave.kafka.streams.KafkaStreamsTracing.filter(String, Predicate<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.filterNot(String, Predicate<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.flatMap(String, KeyValueMapper<K, V, Iterable<KeyValue<KR, VR>>>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.foreach(String, ForeachAction<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.map(String, KeyValueMapper<K, V, KeyValue<KR, VR>>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.mapValues(String, ValueMapperWithKey<K, V, VR>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.mark(String)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.markAsFiltered(String, Predicate<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.markAsNotFiltered(String, Predicate<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.peek(String, ForeachAction<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.processor(String, ProcessorSupplier<K, V>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.transformer(String, TransformerSupplier<K, V, R>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.valueTransformer(String, ValueTransformerSupplier<V, VR>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.
brave.kafka.streams.KafkaStreamsTracing.valueTransformerWithKey(String, ValueTransformerWithKeySupplier<K, V, VR>)	Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.