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"
session_timeout_ms => 60000
auto_offset_reset => "earliest"
enable_auto_commit => false
decorate_events => true
codec => "json"
}
Please guide me for the same