I have installed this on my mac Catalina. I am doing a bin/confluent local services start
Zookeeper starts successfully,
Kafka fails to start. This is what I see in the logs, I have deleted all the kafka related directories in /tmp/
[2021-03-24 09:15:09,079] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-03-24 09:15:09,175] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalAccessError: Receiver class scala/collection/mutable/HashSet$ must be the current class or a subtype of interface scala/collection/IterableFactory
at scala.collection.IterableFactory.apply$(Factory.scala:103)
at kafka.utils.VerifiableProperties.<init>(VerifiableProperties.scala:28)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:33)
at kafka.Kafka$.main(Kafka.scala:68)
at kafka.Kafka.main(Kafka.scala)
hmm is there a stdout file in the kafka directory?
after starting which information are shown on your shell?
Should be something like this:
Using CONFLUENT_CURRENT: /var/folders/hj/rb1_1mlj5sj5frs7wq9fjlt00000gn/T/confluent.583529
Starting ZooKeeper
ZooKeeper is [UP]
Starting Kafka
Kafka is [UP]
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/Users/hadoop/hadoop-2.7.3/share/hadoop/common/lib/slf4j-log4j12-1.7.10.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/hadoop/hbase-1.2.6/lib/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/hadoop/apache-hive-2.1.1-bin/lib/log4j-slf4j-impl-2.4.1.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/Users/hadoop/confluent-6.1.1/share/java/kafka/slf4j-log4j12-1.7.30.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory]
[2021-03-24 18:16:34,153] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-03-24 18:16:34,253] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IllegalAccessError: Receiver class scala/collection/mutable/HashSet$ must be the current class or a subtype of interface scala/collection/IterableFactory
at scala.collection.IterableFactory.apply$(Factory.scala:103)
at kafka.utils.VerifiableProperties.(VerifiableProperties.scala:28)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:33)
[2021-03-28 09:07:44,503] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-03-28 09:07:44,616] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IncompatibleClassChangeError: Class scala.collection.mutable.HashSet$ does not implement the requested interface scala.collection.IterableFactory
at scala.collection.IterableFactory.apply(Factory.scala:103)
at scala.collection.IterableFactory.apply$(Factory.scala:103)
at kafka.utils.VerifiableProperties.(VerifiableProperties.scala:28)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:33)
at kafka.Kafka$.main(Kafka.scala:68)
at kafka.Kafka.main(Kafka.scala)
[2021-03-28 09:14:50,469] INFO Registered kafka:type=kafka.Log4jController MBean (kafka.utils.Log4jControllerRegistration$)
[2021-03-28 09:14:50,571] ERROR Exiting Kafka due to fatal exception (kafka.Kafka$)
java.lang.IncompatibleClassChangeError: Class scala.collection.mutable.HashSet$ does not implement the requested interface scala.collection.IterableFactory
at scala.collection.IterableFactory.apply(Factory.scala:103)
at scala.collection.IterableFactory.apply$(Factory.scala:103)
at kafka.utils.VerifiableProperties.(VerifiableProperties.scala:28)
at kafka.server.KafkaServerStartable$.fromProps(KafkaServerStartable.scala:33)