Kafunc is a library to provide a means to interact with Kafka topics as if they
were a Clojure seq
. They are lazily created by polling a consumer, and
further polls are only done when the end of that seq is reached. Similarly, a
seq
of records can be sent to various topics/partitions.
-
Notifications
You must be signed in to change notification settings - Fork 1
Kafunc - A less imperative approach to Kafka
License
jasongraffius/kafunc
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
Kafunc - A less imperative approach to Kafka
Resources
License
Stars
Watchers
Forks
Packages 0
No packages published