Ed Mitchell
Ed Mitchell
@kamilmysliwiec Can this be considered for merge?
Sounds good to me! No problem
Yep, this breaks us too.
I think this issue is missing some more detail to clarify whether this is expected behavior or not. 1. Does your topic have multiple partitions? 2. If there is more...
That's just how eachMessage for KafkaJS works. It processes each topic-partition sequentially one at a time. You need to set that partitionsConsumedConcurrently to get what you want. You're saying this...
Does it have to be a breaking change? Could it be introduced as a new transport type and mark the old one for deprecation?
I recently ran into this also trying to do a DLQ with Micronaut Kafka. I had to fiddle with the code really hard in order to accomplish two things: 1....
Added the configure call to AbstractKafkaConsumerConfiguration and AbstractKafkaProducerConfiguration
Hey. I'll go ahead and close this. We ended up working around it in our own way. Thanks!
We recently ran into this as well, looks like the workaround is to hit enter on the `SSO session name (Recommended): ` prompt, and the CLI will use the old...