Page History

...

So the general approach is to identify how to inject requests and then set the appropriate AuthenticationRequestEnqueuer implementation on the SaslChannelBuilder.  In addition to Including the above examples, the PR also includes implementations for adds re-authentication support for the following:

• org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient
  • org.apache.kafka.clients.consumer.KafkaConsumer

  • org.apache.kafka.connect.runtime.distributed.WorkerGroupMember

• kafka.controller.ControllerChannelManager
• org.apache.kafka.clients.admin.KafkaAdminClient

...

• org.apache.kafka.clients.producer.KafkaProducer

...

• kafka.coordinator.transaction.TransactionMarkerChannelManager

...

...

• kafka.server.ReplicaFetcherBlockingSend (kafka.server.ReplicaFetcherThread)


There is no intent to include code in the PR to re-authenticate connections originating from these classes:

...