Package brave.kafka.streams
Class TracingFilterValueTransformerWithKeySupplier<K,V>
- java.lang.Object
-
- brave.kafka.streams.TracingFilterValueTransformerWithKeySupplier<K,V>
-
- All Implemented Interfaces:
org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<K,V,V>
,org.apache.kafka.streams.processor.ConnectedStoreProvider
public class TracingFilterValueTransformerWithKeySupplier<K,V> extends Object implements org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<K,V,V>
-
-
Constructor Summary
Constructors Constructor Description TracingFilterValueTransformerWithKeySupplier(KafkaStreamsTracing kafkaStreamsTracing, String spanName, org.apache.kafka.streams.kstream.Predicate<K,V> delegatePredicate, boolean filterNot)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.apache.kafka.streams.kstream.ValueTransformerWithKey<K,V,V>
get()
-
-
-
Constructor Detail
-
TracingFilterValueTransformerWithKeySupplier
public TracingFilterValueTransformerWithKeySupplier(KafkaStreamsTracing kafkaStreamsTracing, String spanName, org.apache.kafka.streams.kstream.Predicate<K,V> delegatePredicate, boolean filterNot)
-
-