[
https://issues.apache.org/jira/browse/METRON-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16249672#comment-16249672
]
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_r150558807
--- 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 --
Well, if `metron.j2` were not available as environment variables for REST,
how does `metron-rest.sh` get the spring profile to use (the
`METRON_SPRING_PROFILES_ACTIVE` variable)?
> 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)
