KafkaTestUtils getCurrentOffset() could take a AdminClient as argument #2218
Description
Expected Behavior
I'd like to be able to pass AdminClient as a argument to this method. That way I can initialise the AdminClient with relevant SSL properties to connect to a SSL cluster.
Current Behavior
Not able to pass SSL connection properties to AdminClient. It only uses bootstrap.servers at the moment.
Context
I cannot use this method at the moment to connect to a SSL cluster in my tests