Class 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 Detail

      • TracingFilterValueTransformerWithKeySupplier

        public TracingFilterValueTransformerWithKeySupplier​(KafkaStreamsTracing kafkaStreamsTracing,
                                                            String spanName,
                                                            org.apache.kafka.streams.kstream.Predicate<K,​V> delegatePredicate,
                                                            boolean filterNot)
    • Method Detail

      • get

        public org.apache.kafka.streams.kstream.ValueTransformerWithKey<K,​V,​V> get()
        Specified by:
        get in interface org.apache.kafka.streams.kstream.ValueTransformerWithKeySupplier<K,​V,​V>