Re: Specify leader when doing partition reassignment

2015-08-05 Thread Jilin Xie
Check the --replica-assignment parameter of the kafka-topics.sh. It does what you need. And there should also be similar configs in the api if you wanna do so by coding. On Wed, Aug 5, 2015 at 6:18 PM, tao xiao wrote: > Hi team, > > Is it possible to specify a leader broker for each topic parti

Re: kafka.common.FailedToSendMessageException: Failed to send messages after 3 tries.

2015-08-04 Thread Jilin Xie
Some suggestions: Check the existence of the topic. Check the firewall of the broker... Try telnet or something to make sure it's available. Try run the producer on the broker machine. Since you get this error, this code is functioning. I think it's some configuration an

Re: Choosing brokers when creating topics

2015-07-27 Thread Jilin Xie
ion for kafka-topics.sh. It allows you to > specify which brokers to assign as replicas instead of relying on the > assignments being made automatically. > > -Ewen > > On Mon, Jul 27, 2015 at 12:25 AM, Jilin Xie > wrote: > > > Hi > > Is it possible to choose whic

Choosing brokers when creating topics

2015-07-27 Thread Jilin Xie
Hi Is it possible to choose which brokers to use when creating a topic? The general command of creating topic is: *bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test* What I'm looking for is: *bin/kafka-topics.sh --create . "--br