Andrew Schofield
Andrew Schofield
It all depends upon how you have set up security. If you're using Apache Kafka, you need to look at the Kafka documentation such as https://kafka.apache.org/documentation/#security_sasl. Then you configure the...
It does.
@DL1231 I'm interested in getting group configs working. This PR is quite out of date, in particular because there's been a lot of refactoring of configs in Kafka recently. Would...
@DL1231 Yes, I'll give the updated code a detailed review in the next few days. Thanks for rebasing it.
https://issues.apache.org/jira/browse/KAFKA-17855 is the continuation of this work which depends upon KIP-1050.
I tried this code and it didn't really behave quite right I feel. I did: * Create 2 topics T1 and T2 * Reset offsets of consumer group G1 consuming...
Code looks good to me, but I got a failure of the new test: ```Test Run :tools:test > Gradle Test Executor 113 > DescribeConsumerGroupTest > testDescribeAllExistingGroupsWithSomeDeletedTopics(ClusterInstance) > testDescribeAllExistingGroupsWithSomeDeletedTopics [1] Type=Raft-Combined,...
I agree with @lianetm here. If my application is closing with some timeout and the user tries to interrupt the program, what do we want it to do? We want...
@JimmyWang6 There's a build failure due to spotless check. Please resolve it and merge latest changes.
@JimmyWang6 I've spent a while trying out this code and I wasn't able to get the majority of the error scenarios to work as I expected. The problem I think...