Closed patrickmay closed 5 years ago
:thinking: The code you posted worked fine for me:
(test-produce "test-topic-1" "key-1" "value-1")
(test-consume "test-topic-1")
;; the call to test-consume printed:
;; Subscribed: "127.0.0.1:9092", #("test-topic-1").
;; Message received or poll expired.
;; Received message: ("key-1") "value-1"
;; Unsubscribing.
If you're still not having any luck, can you share your cl-rdkafka and librdkafka versions? Here's what I'm running:
(cl-rdkafka/ll:rd-kafka-version-str) ; => "0.9.3"
(asdf:component-version (asdf:find-system 'cl-rdkafka)) ; => "0.2.2"
The issue appears to be related to Emacs and Slime. When I run the consumer test in a standalone SBCL image, it works fine. Inside of Slime, something gets confused (possibly me).
Thanks for checking.
I'm testing the latest release with these two functions:
and
When I monitor the topic with kafka-console-consumer, I see the messages produced by test-produce. When I run test-consumer and send messages with kafka-console-producer, it gets the messages. When I send messages with test-producer, test-consumer does not see them. Please tell me I'm making a foolish mistake.