Question
Tata Consultancy Services
IN
Last activity: 16 Oct 2018 0:17 EDT
Kafka integration
Hi,
I have Configured JAAS file for Kafka but in pega Kafka configuration rule still getting “No JAAS configuration file set”at authentication section. Please let me know how ca we resolve this issue.
configuration details which i have done
Pega and Kafka are on same server
JAAS file Name: kafka_server_jaas.conf
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret"
user_alice="alice-secret";
};
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="alice"
password="alice-secret";
};
Before starting kafka executing below command
export KAFKA_OPTS="-Djava.security.auth.login.config=/software/kafka_2.11-1.0.0/config/kafka_server_jaas.conf"
updated server.properties and consumer.properties
File:server.properties
listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
listener.security.protocol.map=SASL_PLAINTEXT:SASL_PLAINTEXT
File consumer. Properties:
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
Please let me know if I missed any other configuration.
Please let me know the solution ASAP If any one have idea.
Regards,
Srinivas
Hi,
I have Configured JAAS file for Kafka but in pega Kafka configuration rule still getting “No JAAS configuration file set”at authentication section. Please let me know how ca we resolve this issue.
configuration details which i have done
Pega and Kafka are on same server
JAAS file Name: kafka_server_jaas.conf
KafkaServer {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="admin"
password="admin-secret"
user_admin="admin-secret"
user_alice="alice-secret";
};
KafkaClient {
org.apache.kafka.common.security.plain.PlainLoginModule required
username="alice"
password="alice-secret";
};
Before starting kafka executing below command
export KAFKA_OPTS="-Djava.security.auth.login.config=/software/kafka_2.11-1.0.0/config/kafka_server_jaas.conf"
updated server.properties and consumer.properties
File:server.properties
listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
listener.security.protocol.map=SASL_PLAINTEXT:SASL_PLAINTEXT
File consumer. Properties:
security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
Please let me know if I missed any other configuration.
Please let me know the solution ASAP If any one have idea.
Regards,
Srinivas
***Updated by moderator: Lochan to update platform capability***