Github user cestella commented on a diff in the pull request:
https://github.com/apache/metron/pull/826#discussion_r151149320
--- Diff:
metron-interface/metron-rest/src/main/java/org/apache/metron/rest/config/KafkaConfig.java
---
@@ -108,6 +108,9 @@ public ZkUtils zkUtils() {
producerConfig.put("key.serializer",
"org.apache.kafka.common.serialization.StringSerializer");
producerConfig.put("value.serializer",
"org.apache.kafka.common.serialization.StringSerializer");
producerConfig.put("request.required.acks", 1);
+ if
(environment.getProperty(MetronRestConstants.KERBEROS_ENABLED_SPRING_PROPERTY,
Boolean.class, false)) {
+ producerConfig.put("security.protocol", "SASL_PLAINTEXT");
--- End diff --
I submitted a [PR](https://github.com/merrimanr/incubator-metron/pull/35)
against your branch with my proposed solution to this. It fixes the issue for
both the producer and consumer configs. If you choose to accept it, you can do
it without my attribution.
---
