...
For example, the org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient
class provides the authenticationRequestEnqueuer()
method that yields an instance that invokes ConsumerNetworkClient.send(Node, AbstractRequest.Builder<?>)
; it is then a simple matter of adding the following code to the constructors of the org.apache.kafka.clients.consumer.KafkaConsumer
and org.apache.kafka.connect.runtime.distributed.WorkerGroupMember
classes, which use ConsumerNetworkClient
for their connectivity:
Code Block | ||||
---|---|---|---|---|
| ||||
if (channelBuilder instanceof SaslChannelBuilder) ((SaslChannelBuilder) channelBuilder).authenticationRequestEnqueuer(client.authenticationRequestEnqueuer()); |
...