Kafka Streaming

Authentication

IMPORTANT: Credentials are injected automatically by a proxy layer. Do NOT check for KAFKA_SASL_PASSWORD in environment variables - it won't be visible to you. Just run the scripts directly; authentication is handled transparently.

Configuration environment variables you CAN check (non-secret):

• KAFKA_BOOTSTRAP_SERVERS - Kafka broker addresses
• KAFKA_SECURITY_PROTOCOL - Security protocol (PLAINTEXT, SSL, SASL_SSL, SASL_PLAINTEXT)

MANDATORY: Broker-First Investigation

Start with broker info, then check topics and consumer groups.

BROKER INFO → LIST TOPICS → DESCRIBE TOPIC → CHECK CONSUMER LAG