B C F G K M N P S T V
All Classes All Packages
All Classes All Packages
All Classes All Packages
B
- brave.kafka.streams - package brave.kafka.streams
- build() - Method in class brave.kafka.streams.KafkaStreamsTracing.Builder
C
- create(KafkaTracing) - Static method in class brave.kafka.streams.KafkaStreamsTracing
- create(MessagingTracing) - Static method in class brave.kafka.streams.KafkaStreamsTracing
- create(Tracing) - Static method in class brave.kafka.streams.KafkaStreamsTracing
F
- filter(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a filter transformer.
- filterNot(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a filterNot transformer.
- flatMap(String, KeyValueMapper<K, V, Iterable<KeyValue<KR, VR>>>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a flatMap transformer, similar to
KStream.flatMap(KeyValueMapper)
, where its mapper action will be recorded in a new span with the indicated name. - foreach(String, ForeachAction<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a foreach processor, similar to
KStream.foreach(ForeachAction)
, where its action will be recorded in a new span with the indicated name.
G
- get() - Method in class brave.kafka.streams.TracingFilterTransformerSupplier
- get() - Method in class brave.kafka.streams.TracingFilterValueTransformerWithKeySupplier
K
- kafkaClientSupplier() - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Provides a
KafkaClientSupplier
with tracing enabled, hence Producer and Consumer operations will be traced. - kafkaStreams(Topology, Properties) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Creates a
KafkaStreams
instance with a tracing-enabledKafkaClientSupplier
. - KafkaStreamsTracing - Class in brave.kafka.streams
-
Use this class to decorate Kafka Stream Topologies and enable Tracing.
- KafkaStreamsTracing.Builder - Class in brave.kafka.streams
M
- map(String, KeyValueMapper<K, V, KeyValue<KR, VR>>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a map transformer, similar to
KStream.map(KeyValueMapper)
, where its mapper action will be recorded in a new span with the indicated name. - mapValues(String, ValueMapper<V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a mapValues transformer, similar to
KStream.mapValues(ValueMapper)
, where its mapper action will be recorded in a new span with the indicated name. - mapValues(String, ValueMapperWithKey<K, V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a mapValues transformer, similar to
KStream.mapValues(ValueMapperWithKey)
, where its mapper action will be recorded in a new span with the indicated name. - mark(String) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a mark transformer, similar to
KStream.peek(ForeachAction)
, but no action is executed. - markAsFiltered(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a markAsFiltered valueTransformer.
- markAsNotFiltered(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a markAsNotFiltered valueTransformer.
N
- newBuilder(MessagingTracing) - Static method in class brave.kafka.streams.KafkaStreamsTracing
- newBuilder(Tracing) - Static method in class brave.kafka.streams.KafkaStreamsTracing
P
- peek(String, ForeachAction<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a peek transformer, similar to
KStream.peek(ForeachAction)
, where its action will be recorded in a new span with the indicated name. - processor(String, ProcessorSupplier<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a tracing-decorated
ProcessorSupplier
S
- singleRootSpanOnReceiveBatch(boolean) - Method in class brave.kafka.streams.KafkaStreamsTracing.Builder
-
Controls the sharing of a
poll
span for incoming spans with no trace context.
T
- TracingFilterTransformerSupplier<K,V> - Class in brave.kafka.streams
- TracingFilterTransformerSupplier(KafkaStreamsTracing, String, Predicate<K, V>, boolean) - Constructor for class brave.kafka.streams.TracingFilterTransformerSupplier
- TracingFilterValueTransformerWithKeySupplier<K,V> - Class in brave.kafka.streams
- TracingFilterValueTransformerWithKeySupplier(KafkaStreamsTracing, String, Predicate<K, V>, boolean) - Constructor for class brave.kafka.streams.TracingFilterValueTransformerWithKeySupplier
- transformer(String, TransformerSupplier<K, V, R>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a tracing-decorated
TransformerSupplier
V
- valueTransformer(String, ValueTransformerSupplier<V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a tracing-decorated
ValueTransformerSupplier
- valueTransformerWithKey(String, ValueTransformerWithKeySupplier<K, V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing
-
Create a tracing-decorated
ValueTransformerWithKeySupplier
All Classes All Packages