An Azure real-time data ingestion service.
Hi @Kumar Sugandh ,
Thank you for the update.
Since you've confirmed that:
- The consumer is able to subscribe successfully.
- The Event Hub name and SAS policy are correct.
- The SAS policy has both Listen and Send permissions.
it appears that authentication and connectivity are working as expected.
To investigate why the partition count is being returned as 0, could you please provide the following information?
- Which Kafka client version are you using?
- Which Java version are you running?
- Could you share your Kafka consumer configuration (with sensitive information redacted), especially the following properties?
bootstrap.serverssecurity.protocolsasl.mechanismsasl.jaas.configrequest.timeout.msmetadata.max.age.ms - Please enable DEBUG logging for the Kafka client and share the MetadataRequest and MetadataResponse immediately after the consumer subscribes.
- Could you confirm whether calling
partitionsFor("<event-hub-name>")also returns 0 partitions, or is the issue only observed aftersubscribe()? - Are you able to reproduce the same behavior using another Kafka client (for example, the Kafka console consumer or a simple sample application)?
This information will help determine whether the metadata returned by Azure Event Hubs is incorrect or whether the Kafka client is not processing the metadata as expected.
Looking forward to your update.