hub.io/clj-kafka/clj-kafka.zk.html#var-set-offset.21
>
> Thanks,
> Ragnar
>
> On Friday, 12 June 2015 18:23:23 UTC+1, Omri Hurvitz wrote:
>>
>> Hi Paul.
>>
>> This looks great - I am looking forward to replace my hacked wrapper for
>> the Java (and Scala...) AP
Hi Paul.
This looks great - I am looking forward to replace my hacked wrapper for
the Java (and Scala...) API with this code.
One question: if I have a zk consumer stream with auto.commit.enable set to
false, how do I manually commit the changes?
Thanks,
Omri
On Friday, June 12, 2015 at 11:
te multiple disparate
> chunks of code will update it (all within the same thread) felt idiomatic.
> - the initial (binding) is at the transaction level, subject updates are
> within the transaction.
>
> On 26 May 2015, at 17:38, Omri Hurvitz >
> wrote:
>
> If you always
If you always access *callbacks* as a thread-local, IE in the same thread,
why do you need it to be an atom? You can just rebind it using set! instead
of swap!.
Beyond that, I think that using thread locals this way is very useful when
you want to limit the need for implementations to know your
