<?xml version="1.0" encoding="UTF-8"?>
<rss xmlns:content="http://purl.org/rss/1.0/modules/content/" xmlns:dc="http://purl.org/dc/elements/1.1/" xmlns:rdf="http://www.w3.org/1999/02/22-rdf-syntax-ns#" xmlns:taxo="http://purl.org/rss/1.0/modules/taxonomy/" version="2.0">
  <channel>
    <title>question Re: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL in Archives of Support Questions (Read Only)</title>
    <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/No-enum-constant-org-apache-kafka-common-protocol/m-p/196944#M71363</link>
    <description>&lt;P&gt;The issue is resolved by using -PHDP-2.5.0.0 option when I compile metron.&lt;/P&gt;</description>
    <pubDate>Wed, 15 Nov 2017 21:34:33 GMT</pubDate>
    <dc:creator>dms1122</dc:creator>
    <dc:date>2017-11-15T21:34:33Z</dc:date>
    <item>
      <title>No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL</title>
      <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/No-enum-constant-org-apache-kafka-common-protocol/m-p/196943#M71362</link>
      <description>&lt;P&gt;I'm facing following error, can you please help me to resolve it:&lt;/P&gt;&lt;PRE&gt;2017-11-14 16:39:55.489 o.a.s.util Thread-17-kafkaSpout-executor[4 4] [ERROR] Async loop died!
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:702) ~[stormjar.jar:?]
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:557) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault.createConsumer(KafkaConsumerFactoryDefault.java:26) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.KafkaSpout.subscribeKafkaConsumer(KafkaSpout.java:452) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:445) ~[stormjar.jar:?]
        at org.apache.storm.daemon.executor$fn__6505$fn__6520$fn__6551.invoke(executor.clj:646) ~[storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
        at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484) [storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL
        at java.lang.Enum.valueOf(Enum.java:238) ~[?:1.8.0_131]
        at org.apache.kafka.common.protocol.SecurityProtocol.valueOf(SecurityProtocol.java:28) ~[stormjar.jar:?]
        at org.apache.kafka.common.protocol.SecurityProtocol.forName(SecurityProtocol.java:89) ~[stormjar.jar:?]
        at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:79) ~[stormjar.jar:?]
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:623) ~[stormjar.jar:?]
        ... 8 more
2017-11-14 16:39:55.495 o.a.s.d.executor Thread-17-kafkaSpout-executor[4 4] [ERROR]
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:702) ~[stormjar.jar:?]
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:557) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.internal.KafkaConsumerFactoryDefault.createConsumer(KafkaConsumerFactoryDefault.java:26) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.KafkaSpout.subscribeKafkaConsumer(KafkaSpout.java:452) ~[stormjar.jar:?]
        at org.apache.storm.kafka.spout.KafkaSpout.activate(KafkaSpout.java:445) ~[stormjar.jar:?]
        at org.apache.storm.daemon.executor$fn__6505$fn__6520$fn__6551.invoke(executor.clj:646) ~[storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
        at org.apache.storm.util$async_loop$fn__554.invoke(util.clj:484) [storm-core-1.0.1.2.5.5.0-157.jar:1.0.1.2.5.5.0-157]
        at clojure.lang.AFn.run(AFn.java:22) [clojure-1.7.0.jar:?]
        at java.lang.Thread.run(Thread.java:748) [?:1.8.0_131]
Caused by: java.lang.IllegalArgumentException: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL
        at java.lang.Enum.valueOf(Enum.java:238) ~[?:1.8.0_131]
        at org.apache.kafka.common.protocol.SecurityProtocol.valueOf(SecurityProtocol.java:28) ~[stormjar.jar:?]
        at org.apache.kafka.common.protocol.SecurityProtocol.forName(SecurityProtocol.java:89) ~[stormjar.jar:?]
        at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:79) ~[stormjar.jar:?]
        at org.apache.kafka.clients.consumer.KafkaConsumer.&amp;lt;init&amp;gt;(KafkaConsumer.java:623) ~[stormjar.jar:?]
        ... 8 more
&lt;/PRE&gt;</description>
      <pubDate>Wed, 15 Nov 2017 03:26:49 GMT</pubDate>
      <guid>https://community.cloudera.com/t5/Archives-of-Support-Questions/No-enum-constant-org-apache-kafka-common-protocol/m-p/196943#M71362</guid>
      <dc:creator>dms1122</dc:creator>
      <dc:date>2017-11-15T03:26:49Z</dc:date>
    </item>
    <item>
      <title>Re: No enum constant org.apache.kafka.common.protocol.SecurityProtocol.PLAINTEXTSASL</title>
      <link>https://community.cloudera.com/t5/Archives-of-Support-Questions/No-enum-constant-org-apache-kafka-common-protocol/m-p/196944#M71363</link>
      <description>&lt;P&gt;The issue is resolved by using -PHDP-2.5.0.0 option when I compile metron.&lt;/P&gt;</description>
      <pubDate>Wed, 15 Nov 2017 21:34:33 GMT</pubDate>
      <guid>https://community.cloudera.com/t5/Archives-of-Support-Questions/No-enum-constant-org-apache-kafka-common-protocol/m-p/196944#M71363</guid>
      <dc:creator>dms1122</dc:creator>
      <dc:date>2017-11-15T21:34:33Z</dc:date>
    </item>
  </channel>
</rss>

