Vincent Maurin

I am not sure the approach to filter out file will be the proper one. With glob, there is an order from which files are processed, thus depending on the...

It seems an implementation using `addUsedSchema` would be more adapted to solve the issue, so appart from the tests, should we start a new PR ? I am doing experimentation...

On my side, I ended up by using ajv directly, here my script with [ajv 8.6.0](https://npmjs.com/package/ajv) and [ajv-formats 2.1.1](https://npmjs.com/package/ajv-formats) ```js const Ajv = require('ajv'); const fs = require('fs'); const path...

I encountered the same issue with a topic with 3 partitions, containing json document. Messages are missing when I am consuming all partitions, but they are there when consuming partition...

Yes, it is also solving the problem. Maybe then @mt3593 you are in the same situation ?

The reason is here https://github.com/wurstmeister/kafka-docker/wiki#why-is-varrundockersock-needed The advertised port (and host) is part of Kafka protocol, when you connect to a bootstrap server with a client to get all the brokers...

I am stumbling to the same problem It won't solve the issue, @cal97g the handler is called from the group coordinator task, that is different from the "task" that is...

My current workaround is to have my listener to produce task/futures that my consumer pool can wait on, so I can fully wait for the listener to complete before I...

@ods Thank you for your anwser I actually do want to use them, I was wondering how to be sure it is used/loaded properly : * do they depend on...

I am coming from the Java clients, and, similar to aiokafka, when you have autocommit, you cannot really control the processing guarantee, because the offset commits are performed in a...