If you are using it for tests, this works with Kafka 10 (tune broker
configs as per your req)
public class TestKafkaCluster {
final KafkaServer kafkaServer;
final ZkClient zkClient;
private String zkConnectionString;
public TestKafkaCluster(String zkConnectionString, int kafkaPort
Congrats Ismael
On Tue, Apr 26, 2016 at 12:58 PM, Ismael Juma wrote:
> Thank you Neha and the PMC for the opportunity. I am both grateful and
> excited. :)
>
> And thanks to everyone else in the Kafka community too.
>
> Ismael
>
> On Mon, Apr 25, 2016 at 10:52 PM, Neha Narkhede wrote:
>
> > The
Can some one please review this?
On Fri, Mar 11, 2016 at 12:09 AM, Achanta Vamsi Subhash <
achanta.va...@flipkart.com> wrote:
> Hi,
> I would like to make this into 0.0.10.0 so can someone look into this and
> review?
>
> On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi S
Hi,
I would like to make this into 0.0.10.0 so can someone look into this and
review?
On Wed, Mar 9, 2016 at 10:29 PM, Achanta Vamsi Subhash <
achanta.va...@flipkart.com> wrote:
> Hi all,
>
> https://github.com/apache/kafka/pull/1035
> This pull request will make the log-seg
Hi all,
https://github.com/apache/kafka/pull/1035
This pull request will make the log-segment load parallel with two
configurable properties "log.recovery.threads" and "
log.recovery.max.interval.ms".
On startup, currently the log segments within a logDir are loaded
sequentially when there is a u
;
> Guozhang
>
> On Tue, Feb 2, 2016 at 1:37 AM, Achanta Vamsi Subhash <
> achanta.va...@flipkart.com> wrote:
>
> > Hi all,
> >
> > I am going through the partition assignment logic in the Kafka new
> > consumer. Is there any documentation for the l
Hi all,
I am going through the partition assignment logic in the Kafka new
consumer. Is there any documentation for the logic implemented? It would be
great if some one can write the algorithm for consumer partition assignment
(within a group and across groups).
--
Regards
Vamsi Subhash
