Comments (10)
where do you get the zookeeper hosts?
from pykafka.
I propose:
SamsaClient(zk=None, hosts=None, connection_timeout=30)
where either zk or hosts is required. connection timeout is ignored if zk is provided.
from pykafka.
where do you get the zookeeper hosts?
good point
from pykafka.
what about the threading handler
what about the zookeeper chroot
what about ACLs
what about error handling
from pykafka.
what about the threading handler
what about the zookeeper chroot
what about ACLs
what about error handling
How is this handled now?
from pykafka.
One initializes the kazoo client with applicable settings an passes it in to Samsa
Plaese forgive typos -- sent via phone
On Sep 27, 2012, at 17:53, Jeff Pollard [email protected] wrote:
what about the threading handler
what about the zookeeper chroot
what about ACLs
what about error handlingHow is this handled now?
—
Reply to this email directly or view it on GitHub.
from pykafka.
One initializes the kazoo client with applicable settings an passes it in to Samsa
Right, so the issue is: if Samsa makes a Kazoo client for you, how do you specify all the requirements (ACL, threading handler, etc)?
from pykafka.
Correct
Plaese forgive typos -- sent via phone
On Sep 27, 2012, at 17:58, Jeff Pollard [email protected] wrote:
One initializes the kazoo client with applicable settings an passes it in to Samsa
Right, so the issue is: if Samsa makes a Kazoo client for you, how do you specify all the requirements (ACL, threading handler, etc)?
—
Reply to this email directly or view it on GitHub.
from pykafka.
So in talking with @tkaemming more, I learned that at the time the dependency was declared, kazoo==0.5
was actually the only working version of Kazoo that works with this code. That changes what I thought the rationale was for the version peg to 0.5
, so I'm actually -1 on this change.
I still think dependency injection of the Kazoo requirement is the right story all the time. Moving forward, we should make our Kazoo requirement in Samsa be as open as is possible to support and also guarantee Samsa works - which is something we're all in agreement on I think.
from pykafka.
+1 to what Jeff said
Plaese forgive typos -- sent via phone
On Sep 27, 2012, at 18:17, Jeff Pollard [email protected] wrote:
So in talking with @tkaemming more, I learned that at the time the dependency was declared, kazoo==0.5 was actually the only working version of Kazoo that works with this code. That changes what I thought the rationale was for the version peg to 0.5, so I'm actually -1 on this change.
I still think dependency injection of the Kazoo requirement is the right story all the time. Moving forward, we should make our Kazoo requirement in Samsa be as open as is possible to support and also guarantee Samsa works - which is something we're all in agreement on I think.
—
Reply to this email directly or view it on GitHub.
from pykafka.
Related Issues (20)
- Error codes are out of date
- simpleconsumer.consume return type different
- pykafka producer deadlock on nosetests' integration tests
- check group or all groups LAG
- Suggest to document Partitioner Behavior in more details in Producer
- error discovering offset manager occasionally occurs when get_balanced_consumer
- Dependabot couldn't authenticate with https://pypi.org/simple/
- Producer only takes bytes, please make change to the README to reflect this
- Very slow when I use PyKafka with asyncio
- [Bug?] Exception AttributeError: "'NoneType' object has no attribute 'info'" in <bound method Producer.__del__ of <pykafka.producer.Producer at 0x118635ad0>> ignored
- Getting import _rd_kafka error in all docker images while trying to connect to kafka via pykafka
- the pykafka consumer is too low,
- kafka-test pykafka.exceptions.SocketDisconnectedError HOT 1
- how to ensure message not missing
- data of my topic in kafka is so big,when i get a consumer,i cost so much time and memoery HOT 1
- LZ4 Compression fails with lz4 version 0.10.1
- Does current pykafka version support all the features of kafka broker 1.1.1? Any updates regarding new version of pykafka
- It will cause continuous continue when offset in message > next_offset
- message consumed by pykafka simpleconsumer has timestamp value 0
- Last two messages are not written to the Topic
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from pykafka.