Skip to content
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.

Sign up for GitHub

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

Jump to bottom

High level consumer/producer API #8

Closed
mumrah opened this issue Nov 17, 2012 · 0 comments
Closed

High level consumer/producer API #8

mumrah opened this issue Nov 17, 2012 · 0 comments
Labels
enhancement

Comments

@mumrah
Copy link
Collaborator

mumrah commented Nov 17, 2012

Implement a Queue.Queue that delegates producing/consuming to two multiprocessing.Process
mumrah added a commit that referenced this issue Nov 20, 2012
@mumrah
Add a Queue-like producer/consumer
330ddbc 
Creates a producer process and one consumer process per partition. Uses
`multiprocessing.Queue` for communication between the parent process and
the producer/consumers.

```python
kafka = KafkaClient("localhost", 9092)
q = KafkaQueue(kafka, client="test-queue", partitions=[0,1])
q.put("test")
q.get()
q.close()
kafka.close()
```

Ref #8
mumrah added a commit that referenced this issue Nov 20, 2012
@mumrah
Add some docs and KafkaQueue config
1d0bc78 
Ref #8
@mumrah mumrah closed this as completed Nov 20, 2012
@joe-keen joe-keen mentioned this issue Feb 19, 2016
Closed
@huangcuiyang huangcuiyang mentioned this issue Jan 18, 2020
Closed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees
No one assigned
Labels
enhancement
Projects
None yet
Milestone
No milestone
Development

No branches or pull requests
1 participant
@mumrah