Package brave.kafka.streams
Class TracingFilterTransformerSupplier<K,V>
java.lang.Object
brave.kafka.streams.TracingFilterTransformerSupplier<K,V>
- All Implemented Interfaces:
org.apache.kafka.streams.kstream.TransformerSupplier<K,V,org.apache.kafka.streams.KeyValue<K,V>>
public class TracingFilterTransformerSupplier<K,V> extends Object implements org.apache.kafka.streams.kstream.TransformerSupplier<K,V,org.apache.kafka.streams.KeyValue<K,V>>
-
Constructor Summary
Constructors Constructor Description TracingFilterTransformerSupplier(KafkaStreamsTracing kafkaStreamsTracing, String spanName, org.apache.kafka.streams.kstream.Predicate<K,V> delegatePredicate, boolean filterNot)
-
Method Summary
-
Constructor Details
-
TracingFilterTransformerSupplier
public TracingFilterTransformerSupplier(KafkaStreamsTracing kafkaStreamsTracing, String spanName, org.apache.kafka.streams.kstream.Predicate<K,V> delegatePredicate, boolean filterNot)
-
-
Method Details