(ns kafka-test
(:require [gregor.core :as g]))
(def kafka-zookeeper "127.0.0.1:2181")
(println "topics = " (pr-str (g/topics {:connection-string kafka-zookeeper})))
(g/create-topic {:connection-string kafka-zookeeper} "foobar-wombat" {})
;;;; ERROR BELOW ;;;;;
ncaught 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)
