Great. I will follow your progress. I will use kafka 7.x in the meantime
for development. I am sure you will announce in then group with the 8.x
has a RC for your client?
On Sun, Feb 17, 2013 at 1:23 PM, David Arthur wrote:
> It is indeed pure python
>
>
> On 2/17/13 12:20 AM, David Montgome
It is indeed pure python
On 2/17/13 12:20 AM, David Montgomery wrote:
Key issue with gevent is there can be no C bindings. If pure python then
the sockets can be monkey patched as long as pure python code. I use
gevent to run redis-py to make async calls to redis even though the client
in natu
Key issue with gevent is there can be no C bindings. If pure python then
the sockets can be monkey patched as long as pure python code. I use
gevent to run redis-py to make async calls to redis even though the client
in nature is blocking. I do believe your client is pure python?
Thanks
On Su
Replying to both messages inline:
On 2/16/13 9:07 PM, David Montgomery wrote:
By the way..I assume that python-kafka is gevent safe?
No idea, I've never used greenlet/gevent before. If the question is "are
you doing anything unusual in kafka-python", then the answer is no. Just
basic method ca
By the way..I assume that python-kafka is gevent safe?
Thanks
On Sun, Feb 17, 2013 at 10:04 AM, David Montgomery <
davidmontgom...@gmail.com> wrote:
> Ok...great...I see now about offsets. I see how I can manage on
> restarts. Thanks!
>
> So...considering I am in a disposable machine world th
Ok...great...I see now about offsets. I see how I can manage on restarts.
Thanks!
So...considering I am in a disposable machine world then I will consider
redis as a centralized store. Makes sense?
What is the time frame for v8 release?
On Sun, Feb 17, 2013 at 3:27 AM, David Arthur wr
Greetings!
I am the maintainer of kafka-python. Very cool to see it used in the wild.
The kafka-python library supports the low-level protocols of Kafka 0.7
(Produce/Fetch/MultiProduce/MultiFetch). When you ask Kafka for messages
via a Fetch request, you specify an offset + range (much like re
You need to read the Kafka design docs. Kafka does not delete messages just
because a Consumer reads it. It does not track what messages have been consumed
by any Consumer.
It is up to Consumers to start off where they left off, by always asking for
the right message (via offsets).
Philip
O
