[
https://issues.apache.org/jira/browse/METRON-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16253568#comment-16253568
]
ASF GitHub Bot commented on METRON-1291:
----------------------------------------
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.
> Kafka produce REST endpoint does not work in a Kerberized cluster
> -----------------------------------------------------------------
>
> Key: METRON-1291
> URL: https://issues.apache.org/jira/browse/METRON-1291
> Project: Metron
> Issue Type: Bug
> Reporter: Ryan Merriman
> Assignee: Ryan Merriman
>
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
