-
Notifications
You must be signed in to change notification settings - Fork 0
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
For topics improvements branch #4
Conversation
Support async natively using manifold to get error bubbling. Support topic seeking, both simple and on a per-partition basis. Support throwing errors for both server side returned values and errors internal to the networking stack. Unified config map usable with all client methods.
README.md
Outdated
|
||
#### Send a batch of events asynchronously | ||
;; Subscribe to a topic, registering a new Consumer Group | ||
(def consumer-instance-map @(client/topic-subscribe config "my-consumer-group")) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Lets rename consumer-instance-map to consumer-instance? I think it's fine to make topic-subscribe block so they don't have deref too. It's not like the consumer can do anything in the mean time?
README.md
Outdated
;; | ||
;; Poll the topic using the consumer instance map returned from topic-subscribe. | ||
;; Note that JSON records are returned. | ||
@(client/topic-consumer-poll! config consumer-instance-map) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Dereffable polls are fine tho. What if you get re-ordering of requests when going async though? I guess we can add some queuing/re-ordering at the client level later.
…to develop * 'develop' of github.com:PyroclastIO/pyroclast-clojure: Add additional seek to the beginning test. Better error response handling / messages.
them in `common-response`.
and consumer-instance-map to read functions.
Rework API to be more consistent and universally include docstrings.
Support async natively using manifold to get error bubbling.
Support topic seeking, both simple and on a per-partition basis.
Support throwing errors for both server side returned values and
errors internal to the networking stack.
Unified config map usable with all client methods.