Re: Is there any command can be used to get broker.id on one of broker with command?

2017-02-18 Thread kay James
Although it seems wired, Since the broker.id can be overridden in command line, so the broker.id in config/server.properties might not be the real id. It seems that no official command support the finding broker.id, and Andrew Otto's way is more reasonable. There are also two other ways to find the

optimal retention and deletion policy

2017-02-18 Thread mohammad ahmad
Hi everyone, I am fairly new to kafka so forgive me if this question is trivial. I have a very simple setup for purposes of timing tests as follows: Machine A -> writes to topic 1 (Broker) -> Machine B reads from topic 1 Machine B -> writes message just read to topic 2 (Broker) -> Machine A reads

Re: [VOTE] 0.10.2.0 RC2

2017-02-18 Thread Ewen Cheslack-Postava
This vote passes with 12 +1 votes (4 bindings) and no 0 or -1 votes. +1 votes PMC Members: * Guozhang Wang * Jun Rao * Gwen Shapira * Neha Narkhede Committers: * Ismael Juma * Sriram Subramanian Community: * Tom Crayford * Magnus Edenhill * Mathieu Fenniak * Rajini Sivaram * Manikumar Reddy * Va

Producer acks=1, clean broker shutdown and data loss

2017-02-18 Thread Nick Travers
Hi - I'm trying to understand the expected behavior of the scenario in which I have a producer with `acks=1` (i.e. partition leader acks only) and I cleanly shut down a broker (via `KafkaServer#shutdown`). I am running my test scenario with three brokers (0.10.1.1), with a default replication coun