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

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

filterNot(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

flatMap(String, KeyValueMapper<K, V, Iterable<KeyValue<KR, VR>>>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

foreach(String, ForeachAction<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

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

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

mapValues(String, ValueMapper<V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

mapValues(String, ValueMapperWithKey<K, V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

mark(String) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

markAsFiltered(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

markAsNotFiltered(String, Predicate<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

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

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

process(String, ProcessorSupplier<KIn, VIn, KOut, VOut>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Create a tracing-decorated ProcessorSupplier

processor(String, ProcessorSupplier<K, V>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

processValues(String, FixedKeyProcessorSupplier<KIn, VIn, VOut>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Create a tracing-decorated FixedKeyProcessorSupplier

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

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

V

valueTransformer(String, ValueTransformerSupplier<V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

valueTransformerWithKey(String, ValueTransformerWithKeySupplier<K, V, VR>) - Method in class brave.kafka.streams.KafkaStreamsTracing

Deprecated.

Use KafkaStreamsTracing.process(String, org.apache.kafka.streams.processor.api.ProcessorSupplier) or KafkaStreamsTracing.processValues(String, org.apache.kafka.streams.processor.api.FixedKeyProcessorSupplier) instead.

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