Does anyone know how to use the logstash Kafka input/output plugin with oauth2? I couldn't find any settings with the current plugins. and I'm trying to develop one with the Kafka Java client. It failed with the following message. If I remove the oauth, it works.
I guess the Threads are interrupt by logstash plugin code. But I don't know it yet.
[INFO ] 2022-05-17 04:54:52.933 [Converge PipelineAction::Create] ExpiringCredentialRefreshingLogin - Successfully logged in.
[INFO ] 2022-05-17 04:54:52.938 [kafka-expiring-relogin-thread-C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317] ExpiringCredentialRefreshingLogin - [Principal=:C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317]: Expiring credential re-login thread started.
[INFO ] 2022-05-17 04:54:52.939 [kafka-expiring-relogin-thread-C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317] ExpiringCredentialRefreshingLogin - [Principal=C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317]: Expiring credential valid from 2022-05-17T04:54:52.338+0000 to 2022-05-17T22:54:51.338+0000
[INFO ] 2022-05-17 04:54:52.940 [kafka-expiring-relogin-thread-C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317] ExpiringCredentialRefreshingLogin - [Principal=:C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317]: Expiring credential re-login sleeping until: 2022-05-17T19:44:06.124+0000
[INFO ] 2022-05-17 04:54:52.941 [kafka-expiring-relogin-thread-C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317] ExpiringCredentialRefreshingLogin - [Principal=:C5191a3aeeeebd935fb1d9b5aaf86959cc15ca3e56f7b614ed5328febb0871317]: Expiring credential re-login thread has been interrupted and will exit.
[INFO ] 2022-05-17 04:54:52.943 [Converge PipelineAction::Create] KafkaProducer - [Producer clientId=esbtpt1ecd002] Closing the Kafka producer with timeoutMillis = 0 ms.