| clear query|facets|time |
Search criteria: .
Results from 11 to 17 from
17 (0.471s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: kafka.jar in repositories - Kafka - [mail # user]
|
|
...Hi Jun, Here's my +1 for publishing Kafka (jar and pom.xml with dependencies) to some public repo. That makes it _much_ easier for a project to include Kafka. Note that it'...
|
|
|
Author: Ken Krugler,
2012-05-25, 17:16
|
|
|
Re: Running Kafka in local test mode - Kafka - [mail # user]
|
|
...Hi Hisham, Thanks for chiming in - see below. It's been shutting down properly, but you're right that calling awaitShutdown() ensures that everything has been properly cleaned u...
|
|
|
Author: Ken Krugler,
2012-05-10, 01:14
|
|
|
Re: Running Kafka in local test mode - Kafka - [mail # user]
|
|
...On May 9, 2012, at 2:03pm, Jun Rao wrote: That's what I'm trying to do, yes. I think I do - here's the code from the run() method of my KafakRunnable that I use to run the Kafk...
|
|
|
Author: Ken Krugler,
2012-05-09, 21:47
|
|
|
Re: Running Kafka in local test mode - Kafka - [mail # user]
|
|
...Hi Jun, On May 8, 2012, at 5:40pm, Jun Rao wrote: Thanks - though this is for unit tests. So it needs to be something I can do via standard Java code. Is that possible, or...
|
|
|
Author: Ken Krugler,
2012-05-09, 19:01
|
|
|
Re: Running Kafka in local test mode - Kafka - [mail # user]
|
|
...On May 7, 2012, at 11:10am, Jun Rao wrote: Thanks for the confirmation. But if I delete ZK data at the start of my unit test (to avoid getting "broker already registered" error...
|
|
|
Author: Ken Krugler,
2012-05-09, 00:34
|
|
|
Re: Running Kafka in local test mode - Kafka - [mail # user]
|
|
...I may have answered my own question… Looks like if I call ConsumerConnector#shutdown before interrupting my consumer Runnable, it works because then KafkaMessageStream#iterator#hasNext...
|
|
|
Author: Ken Krugler,
2012-05-06, 16:53
|
|
|
Running Kafka in local test mode - Kafka - [mail # user]
|
|
...Hi all, I'm trying to run Kakfa in a minimal local test environment, but having issues gracefully shutting down. I can start up ZooKeeper/Kafka, and it's running fine. But ...
|
|
|
Author: Ken Krugler,
2012-05-06, 15:21
|
|
|
|
