[GitHub] metron pull request #826: METRON-1291: Kafka produce REST endpoint does not ...

[merrimanr]

Github user merrimanr commented on a diff in the pull request:

    https://github.com/apache/metron/pull/826#discussion_r151450858
  
    --- 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 --
    
    Thanks @cestella.  Turns out this setting was already available so it was a 
simple change.  I also added the default application.yml and adjusted the unit 
test.


---