vertx-kafka-client

vertx-kafka-client copied to clipboard

The kafka-clients upgrade indirectly upgrades snappy-java from 1.1.10.0 to 1.1.10.5 fixing these snappy-java vulnerablities: * https://nvd.nist.gov/vuln/detail/CVE-2023-34453 * https://nvd.nist.gov/vuln/detail/CVE-2023-34454 * https://nvd.nist.gov/vuln/detail/CVE-2023-34455 * https://nvd.nist.gov/vuln/detail/CVE-2023-43642 kafka-clients 3.7.0 requires to bump the test dependency...

julianladisch

### Version 4.5.7 ### Context I saw there were exceptions thrown when using the kafka consumer with a batch handler. ### Do you have a reproducer? ```java @Testcontainers @ExtendWith(VertxExtension.class) class...

afloarea

Blocked thread in KafkaConsumer.poll

4

### Version 4.5.4 ### Context `Thread Thread[vert.x-eventloop-thread-0,5,main] has been blocked for 2748 ms, time limit is 2000 ms` ``` io.vertx.core.VertxException: Thread blocked at java.base/jdk.internal.misc.Unsafe.unpark(Native Method) at java.base/java.util.concurrent.locks.LockSupport.unpark(LockSupport.java:181) at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.signalNext(AbstractQueuedSynchronizer.java:645) at...

sishbi

NullPointerException if kafka producer has partitions that have no leader

7

If kafka is in a unhealthy state and has partitions that currently don't have a leader, it will make the kafkaproducer crash with a NullPointerException. I believe those partitions should...

mouse256

Consume messages on duplicate context

1

#### Describe the feature Consume messages on a duplicate context regardless of whether Vert.x tracing is enabled so that a context's local data can be used amongst handlers. #### Use...

juliantcook

Consumer went to infinite loop when SerializationException throws

6

### Questions I write a Kafka consumer to consume JSON messages, so I use JsonObjectDeserializer, my configuration is: ```kotlin val kafkaConfig: Map = mapOf( "bootstrap.servers" to config.getString("kafka.bootstrap.servers"), "key.deserializer" to "org.apache.kafka.common.serialization.StringDeserializer",...

cyhii

Move blocking send operation to executor thread

9

Hi! :) Thank you for this project.. This PR fixes a blocking call in the `send` method of `KafkaWriteStreamImpl` class, which was detected with the help of BlockHound: We re-ran...

Arooba-git

#### Describe the feature Currently, the [sendOffsetsToTransaction](https://kafka.apache.org/30/javadoc/org/apache/kafka/clients/producer/KafkaProducer.html#sendOffsetsToTransaction(java.util.Map,org.apache.kafka.clients.consumer.ConsumerGroupMetadata)) is not supported. #### Use cases Since this library exposes other transaction related methods, it's not currently possible to commit consumer offsets transactionally...

ahmedriza

### Version 4.3.8 ### Context .onComplete method never gets called after some internal NPE. Caused by netowork instability. ``` partitionInfoConsumer.partitionsFor(topicName) .onComplete(ar -> { ... someWork }) ``` Logs contains: ```...

FDoKE

Kafka Consumer subscribe method eats exceptions producing no output

7

I am using 3.4.2 of vertx and the kafka client for consuming events from a queue. I have found that when some exceptions happen when attempting to subscribe to a...

lonerzzz