# Reg issue while connecting to kafka using kafka input plugin

**URL:** https://discuss.elastic.co/t/reg-issue-while-connecting-to-kafka-using-kafka-input-plugin/379937
**Category:** Logstash
**Created:** [July 9, 2025, 9:22am UTC](https://discuss.elastic.co/t/reg-issue-while-connecting-to-kafka-using-kafka-input-plugin/379937 "2025-07-09T09:22:29Z")
**Posts on this page:** 1
**Page:** 1

<div class="post-metadata">

### Author: ![pradeep-logstashuser](https://sea2.discourse-cdn.com/elastic/user_avatar/discuss.elastic.co/pradeep-logstashuser/32/138018_2.png) [@pradeep-logstashuser](https://discuss.elastic.co/u/pradeep-logstashuser)
#### Post date: [July 9, 2025, 9:22am UTC](https://discuss.elastic.co/t/reg-issue-while-connecting-to-kafka-using-kafka-input-plugin/379937/1 "2025-07-09T09:22:29Z")

</div>

I am using logstash-9.0 version and I try to consume records from kafka using kafka input plugin using sasl\_jaas OAUTHBAREEER method I got an issue in below and I have given logstash kafka-input plugin config also  
Log  
[2025-07-09T05:12:24,740][INFO][org.apache.kafka.common.telemetry.internals.KafkaMetricsCollector][main][1a2af6e6ccd117b6d5a506253b2b6d8c86f0fc40b748b1b5da6efeaba3178f78] initializing Kafka metrics collector [2025-07-09T05:12:24,844][ERROR][org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule][main][1a2af6e6ccd117b6d5a506253b2b6d8c86f0fc40b748b1b5da6efeaba3178f78] No principal name in JWT claim: sub java.io.IOException: No principal name in JWT claim: sub

Config  
kafka {  
bootstrap\_servers =\> "pkc-57yqp2.eastus2.azure.confluent.cloud:9092"  
topics =\> ["my-topic"]  
group\_id =\> "logstash-Lyca-events-stage1"  
security\_protocol =\> "SASL\_SSL"  
sasl\_mechanism =\> "OAUTHBEARER"  
sasl\_jaas\_config =\> "org.apache.kafka.common.security.oauthbearer.OAuthBearerLoginModule required clientId='ggshhsh' clientSecret='secret' scope='scope/.default' extension\_logicalCluster='lkc-wj16ym' extension\_identityPoolId='pool-b7POx';"  
sasl\_oauthbearer\_token\_endpoint\_url =\> "[https://login.microsoftonline.com/e741d71c-c6b6-47b0-803/oauth2/v2.0/token"](https://login.microsoftonline.com/e741d71c-c6b6-47b0-803c-0f3b32b07556/oauth2/v2.0/token%22)  
session\_timeout\_ms =\> 60000  
auto\_offset\_reset =\> "earliest"  
enable\_auto\_commit =\> false  
decorate\_events =\> true  
codec =\> "json"  
}

Please guide me for the same