| clear query|facets|time |
Search criteria: .
Results from 21 to 30 from
156 (0.098s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Proper use of ConsumerConnector - Kafka - [mail # user]
|
|
...“unless you have a good reason to load balance and manage offsets manually”>> In general one consumer connector consumes more than one partition.> In client side, we want to get all...
|
|
|
Author: Joel Koshy,
2012-12-20, 18:06
|
|
|
Re: Proper use of ConsumerConnector - Kafka - [mail # user]
|
|
...In general, you should use the consumer connector - unless you have a goodreason to load balance and manage offsets manually (which is taken care ofin the consumer connector).- Does the Cons...
|
|
|
Author: Joel Koshy,
2012-12-19, 19:16
|
|
|
Re: Unable To Run QuickStart From CLI - Kafka - [mail # user]
|
|
...You will need to use the ConsoleConsumer (see the bin directory) or createa Java/Scala consumer connector.On Wed, Dec 19, 2012 at 9:41 AM, Christopher Alexander <[EMAIL PROTECTED]> wro...
|
|
|
Author: Joel Koshy,
2012-12-19, 19:11
|
|
|
[KAFKA-661] Prevent a shutting down broker from re-entering the ISR - Kafka - [issue]
|
|
...There is a timing issue in controlled shutdown that affects low-volume topics. The leader that is being shut down receives a leaderAndIsrRequest informing it is no longer the leader and thus...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-661
Author: Joel Koshy,
2012-12-07, 01:14
|
|
|
Re: 0.8 dependencies (and maven) - Kafka - [mail # user]
|
|
...It should - yes. So that would in theory unblock KAFKA-133 right? The only reason we needed the hand-built metrics jar is because of some CSV reporter fixes in 3.* which is required for the ...
|
|
|
Author: Joel Koshy,
2012-11-28, 00:45
|
|
|
Re: 0.8 producer -- many questions - Kafka - [mail # user]
|
|
...The requestId for each request-type is written out to the wire (see BoundedByteBufferSend) *ProduceRequest + MessageAndOffset *-- I haven't learned scala that far The off...
|
|
|
Author: Joel Koshy,
2012-11-27, 00:32
|
|
|
Re: producer queue size - Kafka - [mail # user]
|
|
...To use async, set producer.type to async ; The default queue size is 10000; and the default batch size is 200. On Mon, Nov 26, 2012 at 2:28 PM, Jamie Wang wrote: ...
|
|
|
Author: Joel Koshy,
2012-11-27, 00:06
|
|
|
Re: Reading "first available" offset for the partition? - Kafka - [mail # user]
|
|
...You can obtain this information by sending the broker an OffsetRequest. There is also a command-line tool (GetOffsetShell) that can help understand how it works. On Mon, Nov 26, 2012 ...
|
|
|
Author: Joel Koshy,
2012-11-27, 00:02
|
|
|
Re: Understanding how to monitor using JMX attributes - Kafka - [mail # user]
|
|
...The attributes (partition owner stats) that I see are as listed above: (Broker/partition,fetch offset,consumer offset) The JMX operations getOffsetLag and getLatestOffset return the la...
|
|
|
Author: Joel Koshy,
2012-11-21, 22:16
|
|
|
Re: Understanding how to monitor using JMX attributes - Kafka - [mail # user]
|
|
...Hi Mike, What Kafka version are you using? I tried the latest trunk (0.7) and the attributes I see are: Broker/partition,fetch offset,consumer offset The values seem to be correc...
|
|
|
Author: Joel Koshy,
2012-11-21, 18:47
|
|
|
|
