rwadurian/backend/services/identity-service/src/config/kafka.config.ts

export const kafkaConfig = () => ({
  brokers: (process.env.KAFKA_BROKERS || 'localhost:9092').split(','),
  clientId: process.env.KAFKA_CLIENT_ID || 'identity-service',
  groupId: process.env.KAFKA_GROUP_ID || 'identity-service-group',
});