| clear query|facets|time |
Search criteria: .
Results from 111 to 120 from
755 (0.125s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Consume starting at the next incoming message - Kafka - [mail # user]
|
|
...If you are using ZookeeperConsumerConnector, you can delete yourconsumers state from zookeeper (/consumers/) andthen restart the consumer with the auto.offset.reset option set to"largest"Tha...
|
|
|
Author: Neha Narkhede,
2013-04-16, 00:12
|
|
|
Re: Process for accepting code contribution - Kafka - [mail # user]
|
|
...Hi Jamie,Here are the steps and guidelines for contributing to Kafka -http://kafka.apache.org/contributing.htmlPlease let us know how we can improve those.Thanks,NehaOn Mon, Apr 15, 2013 at ...
|
|
|
Author: Neha Narkhede,
2013-04-16, 00:09
|
|
|
Re: Not balancing across multiple brokers - Kafka - [mail # user]
|
|
...Do you use a VIP or zookeeper for producer side load balancing ? Inother words, what are the values you override for "broker.list" and"zk.connect" in the producer config ?Thanks,NehaOn Fri, ...
|
|
|
Author: Neha Narkhede,
2013-04-12, 21:32
|
|
|
Re: Broker to consumer compression - Kafka - [mail # user]
|
|
...That is not available for performance reasons. Broker uses zero-copyto transfer data from disk to the network on the consumer side. If wepost process data already written to disk before send...
|
|
|
Author: Neha Narkhede,
2013-04-12, 21:32
|
|
|
Re: Broker to consumer compression - Kafka - [mail # user]
|
|
...Kafka already supports end-to-end compression which means datatransfer between brokers and consumers is compressed. There are twosupported compression codecs - GZIP and Snappy. The latter is...
|
|
|
Author: Neha Narkhede,
2013-04-12, 19:25
|
|
|
Re: kafka key serializer - Kafka - [mail # user]
|
|
...Correct, I should've been more specific. "key.serializer.class"defaults to whatever "serializer.class" is set to.Thanks,NehaOn Fri, Apr 12, 2013 at 9:12 AM, Soby Chacko wrote:> Hi N...
|
|
|
Author: Neha Narkhede,
2013-04-12, 16:21
|
|
|
Re: kafka key serializer - Kafka - [mail # user]
|
|
...It defaults both key and value serializer to DefaultEncoder, but youcan customize both independently through "key.serializer.class" and"serializer.class" config options.Thanks,NehaOn Fri, Ap...
|
|
|
Author: Neha Narkhede,
2013-04-12, 15:39
|
|
|
Re: Question about Split brain problem for the case of a single consumer per topic - Kafka - [mail # user]
|
|
...Hi Itai,It will be easier to explain things if we know your use case. I'lltake a stab at your questions -1. At most one consumer per topic.2. That thi...
|
|
|
Author: Neha Narkhede,
2013-04-12, 15:21
|
|
|
[KAFKA-862] Error incrementing leader high watermark - Kafka - [issue]
|
|
...2013/04/10 20:04:31.529 ERROR [KafkaApis] [kafka-request-handler-6] [kafka] [] [KafkaApi-270] Error processing ProducerRequest with correlation id 242757885 from client null-13 on foo:3java....
|
|
|
http://issues.apache.org/jira/browse/KAFKA-862
Author: Neha Narkhede,
2013-04-11, 19:55
|
|
|
Re: kafka key serializer - Kafka - [mail # user]
|
|
...It will use DefaultEncoder.Thanks,NehaOn Wed, Apr 10, 2013 at 8:27 AM, Soby Chacko wrote:> If I don't provide an explicit key serializer but a serializer class (for> value encodi...
|
|
|
Author: Neha Narkhede,
2013-04-10, 18:00
|
|
|
|
