Re: [ANN] clj-kafka 0.3.1

2015-06-16 Thread Paul Ingles
Understood- almost all the functions in the zk namespace were intended for occasional/admin type use so they open/close the ZK connection. It should be pretty easy to refactor that around so connections are passed in (allowing you to retain a connection across multiple operations). I'll see if

Re: [ANN] clj-kafka 0.3.1

2015-06-15 Thread Omri Hurvitz
I see it now. I am concerned though that this will create a new zk connection every time I use it. On Friday, June 12, 2015 at 1:46:46 PM UTC-4, Ragnar Dahlén wrote: > > Hi Omri, > > There's clj-kafka.zk/set-offset! for exactly that purpose: > https://pingles.github.io/clj-kafka/clj-kafka.zk.ht

Re: [ANN] clj-kafka 0.3.1

2015-06-12 Thread Henrik Lundahl
Great stuff! Thanks Paul, Ragnar and others! -- Henrik On Fri, Jun 12, 2015 at 5:35 PM, Paul Ingles wrote: > Hi all, > > > I'm delighted to say 0.3.1 is released and available on Clojars. > > > It's been a long while since we've made any big changes to clj-kafka so > I'm very happy to say we'

Re: [ANN] clj-kafka 0.3.1

2015-06-12 Thread Ragnar Dahlén
Hi Omri, There's clj-kafka.zk/set-offset! for exactly that purpose: https://pingles.github.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 wr

Re: [ANN] clj-kafka 0.3.1

2015-06-12 Thread Omri Hurvitz
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:

Re: [ANN] clj-kafka 0.3.1

2015-06-12 Thread Bruce Durling
Paul, This is great news. Looking forward to using it. cheers, Bruce On Fri, Jun 12, 2015 at 4:35 PM, Paul Ingles wrote: > Hi all, > > > I'm delighted to say 0.3.1 is released and available on Clojars. > > > It's been a long while since we've made any big changes to clj-kafka so I'm > very happ

[ANN] clj-kafka 0.3.1

2015-06-12 Thread Paul Ingles
Hi all, I'm delighted to say 0.3.1 is released and available on Clojars. It's been a long while since we've made any big changes to clj-kafka so I'm very happy to say we've caught up over the past couple of days. Most of the changes were the result of submissions from the community but I h