| clear query|facets|time |
Search criteria: .
Results from 11 to 20 from
152 (0.235s).
|
|
|
Loading phrases to help you
refine your search...
|
|
Re: Consumer rebalance per topic - Kafka - [mail # user]
|
|
...(From http://kafka.apache.org/design.html) one potential benefit of theexisting rebalancing logic is to reduce the number of connections tobrokers per consumer instance. However, if you have...
|
|
|
Author: Joel Koshy,
2013-01-08, 20:08
|
|
|
[KAFKA-668] Controlled shutdown admin tool should not require controller JMX url/port to be supplied - Kafka - [issue]
|
|
...The controlled shutdown admin command takes a zookeeper string and also requires the user to supply the controller's jmx url/port. This is a bit annoying since the purpose of the zookeep...
|
|
|
http://issues.apache.org/jira/browse/KAFKA-668
Author: Joel Koshy,
2013-01-02, 22:09
|
|
|
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
|
|
|
|
