vertx-kafka-client

vertx-kafka-client copied to clipboard

resume and pause in KafkaConsumer (reactivex) are not working as expected and causing rebalancing of consumer group

2

### Questions resume and pause in KafkaConsumer (reactivex) are not working as expected and causing rebalancing of consumer group ### Version 3.6.0 ### Context It is causing rebalancing of consumer...

yogs95

Kafka client consumer handler() not receive message after exception

2

I'm using vertx-kafka-client 3.9.1. When i meant to send a message ("abc") to consumer, i got an exception in handler function. After that, i tried to send another message ("xyz"),...

fangwohung

### Questions Getting following exception when I try to build and run with jar file java -jar demo-1.0.0.jar io.vertx.core.impl.NoStackTraceThrowable: Kafka properties file at location kafka.properties is missing. Either specify using...

sudaredd

BufferSerializer not able to work with

1

matzew

Handle consumer exception

5

1. Fixes master branch failure because of ExampleTest 2. Handling the error and fail the handler properly.

barbarosalp

Differing semantics of KafkaConsumer.pause() and pause(TopicPartition)

1

`KafkaConsumer.pause()` will *immediately* stop the `KafkaConsumer` from calling the record handler until `resume()` is called. This includes preventing the processing of buffered messages. In contrast, `KafkaConsumer.pause(TopicPartition)` and `KafkaConsumer.pause(Set)` just correspond...

tombentley

Links in documentation in README.md are broken

1

All Links in documentation in `README.md` in this project are broken.

pwittchen

vertx-kafka (eventloop execute callback) is not the same one ( eventloop execute producer.write)

1

when execute kafak producer write() method，eg: eventloop-1-5 execute wirte method,but the callback is executing in eventloop-3-5, in write method ,i think should add a line like Context context = vertx.getOrCreateContext();...

jiangchuan185

Lost records on frequent commits and pause/resume

10

Hi We are currently experiencing lost records from kafka that are not delivered to the registered data handler. We did some further investigating and testing and there probably seems to...

Seraksab

auto.offset.reset ignored

5

Thanks to your awesome project, my consumer was up and running in minutes. However, I needed to re-consume the entire queue so did a consumer-group offset reset, then started my...

owahab