| clear query|facets|time |
Search criteria: .
Results from 21 to 30 from
120 (0.435s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: .net (c#) kafka client - Kafka - [mail # user]
|
|
...You can certainly use different clients for producers and consumers. E.g., you could have a Python producer, a C producer, and a Scala consumer; or any combination thereof.If you want your c...
|
|
|
Author: David Arthur,
2013-04-04, 13:31
|
|
|
Re: .net (c#) kafka client - Kafka - [mail # user]
|
|
...What is the bridge between C# and Node.js? If you're writing some custom middle man, why not write it in Java or Scala so you can then use the official clients?-DavidOn 4/3/13 3:22 PM, Oleg ...
|
|
|
Author: David Arthur,
2013-04-03, 19:30
|
|
|
0.8 Python client - Kafka - [mail # dev]
|
|
...Hello all,I've been working on updating (i.e., rewriting) my Python client for the impending 0.8 release. Check it out:https://github.com/mumrah/kafka-python/tree/0.8In addition to 0.8 proto...
|
|
|
Author: David Arthur,
2013-04-02, 02:11
|
|
|
Re: Hardware profile - Kafka - [mail # user]
|
|
...Especially in light of replication (broker-broker communication), I'm wondering if all the brokers are in the same rack and what kind of networking interfaces are used (Gigabit ethernet, Fib...
|
|
|
Author: David Arthur,
2013-03-29, 23:44
|
|
|
Re: Hardware profile - Kafka - [mail # user]
|
|
...How many brokers are you (LinkedIn) running? What kind of network topology?On 3/29/13 2:45 PM, Neha Narkhede wrote:> 1. We never share zookeeper and broker on the same hardware. Both need...
|
|
|
Author: David Arthur,
2013-03-29, 18:48
|
|
|
Re: 0.8 build problems - Kafka - [mail # dev]
|
|
...Turns out I needed to remove ~/.sbtNot sure why, or what that means, but it's working now-DavidOn 2/21/13 8:05 PM, Derek Chen-Becker wrote:> Reviewed. I added my comments on the ticket. T...
|
|
|
Author: David Arthur,
2013-03-28, 13:36
|
|
|
Re: log.file.size limit? - Kafka - [mail # user]
|
|
...If you look at the description of the "map" method, it states:size - The size of the region to be mapped; must be non-negative and no greater than Integer.MAX_VALUE-DavidOn 3/25/13 4:37 PM, ...
|
|
|
Author: David Arthur,
2013-03-25, 23:21
|
|
|
Re: log.file.size limit? - Kafka - [mail # user]
|
|
...FileChannel#map docs indicate the max size is Integer.MAX_VALUE, so yea 2gbhttp://docs.oracle.com/javase/6/docs/api/java/nio/channels/FileChannel.html#map(java.nio.channels.FileChannel.MapMo...
|
|
|
Author: David Arthur,
2013-03-25, 19:14
|
|
|
Re: Consume from X messages ago - Kafka - [mail # user]
|
|
...This API is exposed through the SimpleConsumer scala class. See https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/consumer/SimpleConsumer.scala#L60You will need to set ear...
|
|
|
Author: David Arthur,
2013-03-19, 15:49
|
|
|
Re: Consume from X messages ago - Kafka - [mail # user]
|
|
...Using the Offsets API, you can get the latest offset by setting time to -1. Then you subtract 10000There is no guarantee that 10k prior messages exist of course, so you'd need to handle that...
|
|
|
Author: David Arthur,
2013-03-19, 15:17
|
|
|
|
