This page is not created by, affiliated with, or supported by Slack Technologies, Inc.
2021-10-06
Channels
- # babashka (19)
- # beginners (68)
- # calva (9)
- # cider (27)
- # clj-kondo (64)
- # clj-on-windows (2)
- # cljdoc (8)
- # clojure (11)
- # clojure-europe (58)
- # clojure-italy (1)
- # clojure-nl (23)
- # clojure-uk (5)
- # clojurescript (9)
- # cryogen (18)
- # cursive (14)
- # data-science (17)
- # emacs (6)
- # gorilla (6)
- # graphql (1)
- # gratitude (2)
- # holy-lambda (10)
- # introduce-yourself (1)
- # jackdaw (3)
- # jobs (1)
- # leiningen (2)
- # malli (3)
- # missionary (33)
- # off-topic (21)
- # pedestal (7)
- # polylith (8)
- # quil (3)
- # random (1)
- # releases (1)
- # remote-jobs (7)
- # shadow-cljs (18)
- # specter (1)
- # sql (8)
Attempting to get jackdaw working with confluent cloud. Is there something obviously wrong with this:
<config setup>
Edit: figured it out, was using the wrong keysI'm trying to copy/paste the serdes example but using deps.edn for my project and I keep getting the error
2021-10-06T20:09:14.980Z DESKTOP-O6G07JE ERROR [org.apache.kafka.streams.KafkaStreams:489] - stream-client [serdes-f9c3b089-68fc-42f1-8209-322ba909291b] Encountered the following exception during processing and the registered exception handler opted to SHUTDOWN_CLIENT. The streams client is going to shut down now.
org.apache.kafka.streams.processor.internals.StreamThread.run StreamThread.java: 556
org.apache.kafka.streams.processor.internals.StreamThread.runLoop StreamThread.java: 583
org.apache.kafka.streams.processor.internals.StreamThread.runOnce StreamThread.java: 720
org.apache.kafka.streams.processor.internals.StreamThread.pollPhase StreamThread.java: 885
org.apache.kafka.streams.processor.internals.StreamThread.pollRequests StreamThread.java: 925
org.apache.kafka.clients.consumer.KafkaConsumer.poll KafkaConsumer.java: 1206
org.apache.kafka.clients.consumer.KafkaConsumer.poll KafkaConsumer.java: 1226
org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded KafkaConsumer.java: 1257
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll ConsumerCoordinator.java: 508
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup AbstractCoordinator.java: 365
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded AbstractCoordinator.java: 425
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.initiateJoinGroup AbstractCoordinator.java: 503
org.apache.kafka.clients.consumer.internals.AbstractCoordinator.sendJoinGroupRequest AbstractCoordinator.java: 546
org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.metadata ConsumerCoordinator.java: 222
org.apache.kafka.streams.processor.internals.StreamsPartitionAssignor.subscriptionUserData StreamsPartitionAssignor.java: 258
org.apache.kafka.streams.processor.internals.assignment.SubscriptionInfo.<init> SubscriptionInfo.java: 90
org.apache.kafka.streams.internals.generated.SubscriptionInfoData.<init> SubscriptionInfoData.java: 142
java.lang.ClassLoader.loadClass ClassLoader.java: 522
jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass ClassLoaders.java: 168
jdk.internal.loader.BuiltinClassLoader.loadClass BuiltinClassLoader.java: 606
java.lang.ClassNotFoundException: org.apache.kafka.common.Uuid
java.lang.NoClassDefFoundError: org/apache/kafka/common/Uuid
When I try to start the code (https://github.com/FundingCircle/jackdaw/blob/2d1b0a0f2ba860f62a651985794ae5bd3792e136/examples/serdes/src/serdes.clj#L105)
Anyone know what this might be? My current guess is that it's a dependency issueAh, sorry, I keep answering my own questions immediately after I finally give up and ask here. I fixed the above by manually adding deps like this
org.apache.kafka/kafka-streams {:mvn/version "2.8.0"}
org.apache.kafka/kafka-clients {:mvn/version "2.8.0"}
fundingcircle/jackdaw {:mvn/version "0.8.1-drop_clj_time-SNAPSHOT"
:exclusions [org.apache.kafka/kafka-clients]}