Ian Farré
Ian Farré
Any updates now? I'm facing the same problem with the Kafka JS npm package
Hi, do you still plan to merge this PR? It would be awesome to be able to access the topics consumed by a group
I started playing with rust a few weeks ago so I'm not feeling 100% confident about this. I'll give it a try and see what comes out of it. For...
Hi, I expanded the `test_group_membership` test with this: ```rust assert_eq!(consumer_member.assignment().unwrap().len(), 1); let assignment_topic = &consumer_member.assignment().unwrap()[0]; assert_eq!( assignment_topic, &MemberAssignment { partitions: vec![0, 1, 2], topic: topic_name } ); ``` I hope...
Hi @benesch can this be merged?
Hi, I faced the exact same issue some days ago and I came up with this solution: ``` let message = match tokio::time::timeout(timeout, consumer.recv()).await { Ok(Ok(message)) => Ok(Some(message)), Ok(Err(err)) =>...
Hi, I'm stuck with this, anybody has a solution? I'm using the more advanced `client.fetch_messages` method btw
Hi @elmalakomar, you are seeing this error because the CRUD service is struggling to load the provided collections. This means you should give more resources to the service to avoid...