java-kafka-client

java-kafka-client copied to clipboard

Update to Kafka 3.0.0

7

Kafka 3.0.0 is a major release and as such it does some breaking changes such as removes some old methods which were deprecated before and adds new methods etc. This...

scholzj

Doesn't work with Kafka 3.0

1

Using opentracing-contrib/java-kafka-client 0.15.0 with Kafka client >= 3.0.0 leads doesn't work: ``` 2022-03-11T13:45:32.603Z [03608a62-cf2b-4e0d-ba76-85bec1224a9b-app-bfd8b27c-46e3-422f-a692-a6eff7ac2a7a-StreamThread-1] ERROR org.apache.kafka.streams.KafkaStreams - stream-client [03608a62-cf2b-4e0d-ba76-85bec1224a9b-app-bfd8b27c-46e3-422f-a692-a6eff7ac2a7a] Encountered the following exception during processing and Kafka Streams opted to...

cykl

Infinite retry by using DeadLetterPublishingRecoverer with TracingProducerFactory

1

Hi, I found exception which causes to infinite retry by using DeadLetterPublishingRecoverer with TracingProducerFactory together. If TracingProducerFactory injects to DeadLetterPublishingRecoverer then by handling error in consumer will be java.lang.UnsupportedOperationException thrown...

fahtom94

Hi, I have the following issue: I'm using Quarkus with interceptors: ``` ... ... mp.messaging.outgoing.datagen-tickets-out.interceptor.classes=io.opentracing.contrib.kafka.TracingProducerInterceptor ``` I'm reading the documentation and code but I don't find how to modify the...

jaruizes-paradigma

Hi, I have the following issue: ### Expected behavior: When I consume data from a Kafka topic in batch-mode, I expect that a new span for the consumer is added...

chriskn

Cannot pass custom tags to `TracingKafkaUtils. buildAndInjectSpan`

4

Hello all, I found that we cannot pass some custom tags via [`TracingKafkaUtils.buildAndInjectSpan` method](https://github.com/opentracing-contrib/java-kafka-client/blob/1bb43bee257df006eb5df1e105ac23d8c2594667/opentracing-kafka-client/src/main/java/io/opentracing/contrib/kafka/TracingKafkaUtils.java#L59), which we usually need when using this library, so we end up writing our wrapper class...

zrashwani

https://github.com/opentracing-contrib/java-kafka-client/blob/release-0.1.15/opentracing-kafka-client/src/main/java/io/opentracing/contrib/kafka/HeadersMapInjectAdapter.java#L38 ```java @Override public void put(String key, String value) { headers.add(key, value.getBytes(StandardCharsets.UTF_8)); } ``` This just appends headers to the end of the list, and `inject` can happen repeatedly in...

william-tran

Span context propagation from Consumer to Producer

13

I've producer-1 (SignalsProducer) which is consumed by consumer-1 (SignalsConsumer). This consumer then enriches the record and then it becomes producer-2 (EnrichedLeadProducer) which is then consumed by consumer-2 (EnrichedLeadConsumer). These leads...

adurai81

Custom span names for consumers doesn't seem to work

2

Hello, I'm using opentracing-kafka-spring version 0.1.15. I'm trying to set custom span names for producers and consumers. Making it work for producers was very easy and worked immediately, and I...

raphaeldore

Automatic trace continuation

2

Current TracingKafkaConsumer behaviour is to override Consumer#poll to: * create very short lived consumer spans before returning all the records to the caller. * inject span context into record headers...

cykl