| clear query|facets|time |
Search criteria: .
Results from 21 to 30 from
789 (0.17s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: What exactly happens if fetch size is smaller than the next batch (0.72 and high-level consumer) - Kafka - [mail # user]
|
|
...Yes, it is the maxSize parameter in FetchRequest. And the consumer won'tstall unless a single message (compressed or not) is larger than the fetchsize, in this case 300KB. It doesn't matter ...
|
|
|
Author: Neha Narkhede,
2013-06-01, 20:26
|
|
|
Re: question about usage of SimpleConsumer - Kafka - [mail # user]
|
|
...I mean, simple consumerwon't get the offset where it stopped, but the offset of brokers latestoffset.Correct. Also each consumer in Kafka reads data independently from thebroker.Thanks,NehaO...
|
|
|
Author: Neha Narkhede,
2013-06-01, 04:02
|
|
|
[KAFKA-837] Add 0.7->0.8 migration steps doc - Kafka - [issue]
|
|
...We need to document how to migrate data from Kafka 0.7 to Kafka 0.8...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-837
Author: Neha Narkhede,
2013-05-31, 20:36
|
|
|
Re: zookeeper version issue - Kafka - [mail # user]
|
|
...Actually, the version of zookeeper that Kafka 08 and 07 depend on is 3.3.4.Zookeeper 3.3.3 has known serious bugs with lost watchers.Thanks,NehaOn Fri, May 31, 2013 at 10:22 AM, Dennis Halle...
|
|
|
Author: Neha Narkhede,
2013-05-31, 17:35
|
|
|
Re: question about usage of SimpleConsumer - Kafka - [mail # user]
|
|
...getOffsetsBefore sends an RPC call to the Kafka brokers to find out theearliest/latest offset for that topic, partition. In your example, it willget you the latest offset at the time of the ...
|
|
|
Author: Neha Narkhede,
2013-05-31, 15:49
|
|
|
Re: kafka.common.LeaderNotAvailableException: No leader for any partition - Kafka - [mail # user]
|
|
...Can you check if the value for zookeeper.connect is set correctly ? Wechanged the name of some configs in 08, you can find the new config nameshere - http://kafka.apache.org/08/configuration...
|
|
|
Author: Neha Narkhede,
2013-05-30, 20:57
|
|
|
[KAFKA-923] Improve controller failover latency - Kafka - [issue]
|
|
...During controller failover, we do the following things -1. Increment controller epoch 2. Initialize controller context3. Initialize replica state machine4. Initialize partition state machine...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-923
Author: Neha Narkhede,
2013-05-30, 08:39
|
|
|
Re: SimpleConsumer and message offsets - Kafka - [mail # user]
|
|
...If main advantage of SimpleConsumer is so that you can have finer levelcontrol on the offset management. So you have to keep track of offsets. Ifyou don't care about offset management, you c...
|
|
|
Author: Neha Narkhede,
2013-05-29, 20:01
|
|
|
[KAFKA-816] Reduce noise in Kafka server logs due to NotLeaderForPartitionException - Kafka - [issue]
|
|
...NotLeaderForPartitionException is logged at the ERROR level with a full stack trace. But really this is just an informational message on the server when a client with stale metadata sends re...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-816
Author: Neha Narkhede,
2013-05-29, 17:59
|
|
|
Re: About Kafka Users Group around Hadoop Summit - Kafka - [mail # user]
|
|
...Vaibhav,You can plan to be here on Thursday evening. We are still working withHortonworks to see if we can host the meetup at Hadoop Summit venue onThursday evening. If not, we plan to host ...
|
|
|
Author: Neha Narkhede,
2013-05-29, 00:29
|
|
|
|
