Logstash Kafka input and output with oauth

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.

Similar answer.

the Kafka Java client did support callback to login the oauth, now the problem is that the thread is interrupted when it goes to sleep.

I'm not sure which application/process/thread interrupt it, and how to avoid it.

This topic was automatically closed 28 days after the last reply. New replies are no longer allowed.