kafka-error

Code:

(ns kafka-test
  (:require [gregor.core :as g]))


(def kafka-zookeeper "127.0.0.1:2181")
(g/create-topic {:connection-string kafka-zookeeper} "foobar-wombat" {})


Error:


Uncaught exception, not in assertion.
expected: nil
  actual: kafka.admin.AdminOperationException: java.lang.NoSuchFieldError: SINGLETON
 at kafka.admin.AdminUtils$.writeTopicPartitionAssignment (AdminUtils.scala:475)
    kafka.admin.AdminUtils$.createOrUpdateTopicPartitionAssignmentPathInZK (AdminUtils.scala:457)
    kafka.admin.AdminUtils$.createTopic (AdminUtils.scala:415)
    kafka.admin.AdminUtils.createTopic (AdminUtils.scala:-1)
    gregor.core$create_topic.invokeStatic (core.clj:512)
    gregor.core$create_topic.invoke (core.clj:487)
    mondrian.cqrs.job.command_test$make_topic_BANG_.invokeStatic (command_test.clj:59)
    mondrian.cqrs.job.command_test$make_topic_BANG_.invoke (command_test.clj:55)
    mondrian.cqrs.job.command_test$end_to_end_test.invokeStatic (command_test.clj:68)
    mondrian.cqrs.job.command_test$end_to_end_test.doInvoke (command_test.clj:65)
    clojure.lang.RestFn.applyTo (RestFn.java:139)
    clojure.core$apply.invokeStatic (core.clj:659)
    clojure.core$apply.invoke (core.clj:652)
    mondrian.cqrs.job.command_test$end_to_end_test.invokeStatic (command_test.clj:65)
    mondrian.cqrs.job.command_test$end_to_end_test.invoke (command_test.clj:65)
    mondrian.cqrs.job.command_test$fn__34837.invokeStatic (command_test.clj:65)
    mondrian.cqrs.job.command_test/fn (command_test.clj:65)
    clojure.test$test_var$fn__10620.invoke (test.clj:716)
    clojure.test$test_var.invokeStatic (test.clj:716)
    clojure.test$test_var.invoke (test.clj:707)
    clojure.test$test_vars$fn__10646$fn__10651.invoke (test.clj:734)
    mondrian.cqrs.test.system$with_system_fixture$fn__34813.invoke (system.clj:18)
    clojure.test$compose_fixtures$fn__10614$fn__10615.invoke (test.clj:693)
    clojure.test$default_fixture.invokeStatic (test.clj:686)
    clojure.test$default_fixture.invoke (test.clj:682)
    clojure.test$compose_fixtures$fn__10614.invoke (test.clj:693)
    clojure.test$test_vars$fn__10646.invoke (test.clj:734)
    clojure.test$default_fixture.invokeStatic (test.clj:686)
    clojure.test$default_fixture.invoke (test.clj:682)
    clojure.test$test_vars.invokeStatic (test.clj:730)
    clojure.test$test_vars.invoke (test.clj:722)
    pod$test_ns_STAR_$run_tests_STAR___498.invoke (NO_SOURCE_FILE:0)
    pod$test_ns_STAR_.invokeStatic (NO_SOURCE_FILE:0)
    pod$test_ns_STAR_.invoke (NO_SOURCE_FILE:0)
    clojure.core$partial$fn__6857.invoke (core.clj:2604)
    clojure.core$map$fn__6881.invoke (core.clj:2728)
    clojure.lang.LazySeq.sval (LazySeq.java:40)
    clojure.lang.LazySeq.seq (LazySeq.java:49)
    clojure.lang.Cons.next (Cons.java:39)
    clojure.lang.RT.next (RT.java:703)
    clojure.core$next__6406.invokeStatic (core.clj:64)
    clojure.core.protocols$fn__9143.invokeStatic (protocols.clj:168)
    clojure.core.protocols/fn (protocols.clj:124)
    clojure.core.protocols$fn__9098$G__9093__9107.invoke (protocols.clj:19)
    clojure.core.protocols$seq_reduce.invokeStatic (protocols.clj:27)
    clojure.core.protocols$fn__9126.invokeStatic (protocols.clj:75)
    clojure.core.protocols/fn (protocols.clj:75)
    clojure.core.protocols$fn__9072$G__9067__9085.invoke (protocols.clj:13)
    clojure.core$reduce.invokeStatic (core.clj:6700)
    clojure.core$reduce.invoke (core.clj:6686)
    pod$eval36760.invokeStatic (NO_SOURCE_FILE:0)
    pod$eval36760.invoke (NO_SOURCE_FILE:-1)
    clojure.lang.Compiler.eval (Compiler.java:6978)
    clojure.lang.Compiler.eval (Compiler.java:6968)
    clojure.lang.Compiler.eval (Compiler.java:6941)
    clojure.core$eval.invokeStatic (core.clj:3187)
    clojure.core$eval.invoke (core.clj:3183)
    boot.pod$eval_in_STAR_.invoke (pod.clj:468)
    clojure.lang.Var.invoke (Var.java:379)
    org.projectodd.shimdandy.impl.ClojureRuntimeShimImpl.invoke (ClojureRuntimeShimImpl.java:109)
    org.projectodd.shimdandy.impl.ClojureRuntimeShimImpl.invoke (ClojureRuntimeShimImpl.java:102)
    sun.reflect.NativeMethodAccessorImpl.invoke0 (NativeMethodAccessorImpl.java:-2)
    sun.reflect.NativeMethodAccessorImpl.invoke (NativeMethodAccessorImpl.java:62)
    sun.reflect.DelegatingMethodAccessorImpl.invoke (DelegatingMethodAccessorImpl.java:43)
    java.lang.reflect.Method.invoke (Method.java:498)
    clojure.lang.Reflector.invokeMatchingMethod (Reflector.java:93)
    clojure.lang.Reflector.invokeInstanceMethod (Reflector.java:28)
    boot.pod$eval_in_STAR_.invoke (pod.clj:471)
    adzerk.boot_test$eval75$fn__76$fn__85$fn__86.invoke (boot_test.clj:102)
    boot.core$run_tasks.invoke (core.clj:1019)
    boot.core$boot$fn__918.invoke (core.clj:1029)
    clojure.core$binding_conveyor_fn$fn__6772.invoke (core.clj:2020)
    clojure.lang.AFn.call (AFn.java:18)
    java.util.concurrent.FutureTask.run (FutureTask.java:266)
    java.util.concurrent.ThreadPoolExecutor.runWorker (ThreadPoolExecutor.java:1142)
    java.util.concurrent.ThreadPoolExecutor$Worker.run (ThreadPoolExecutor.java:617)
    java.lang.Thread.run (Thread.java:745)