Index

B C F G K M N P S T V
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-enabled KafkaClientSupplier.

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

B C F G K M N P S T V
All Classes|All Packages