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
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
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
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