In Kafka 0.7, topics and partitions are dynamic in the sense that a partition is created when the broker receives the first message for that partition. In Kafka 0.8, there are 2 ways of creating a new topic - 1. Turn on auto.create.topics.enable option on the broker. When the broker receives the first message for a new topic, it creates that topic with num.partitions and default.replication.factor. 2. Use the admin command bin/kafka-create-topic.sh
Thanks, Neha On Sun, Jan 27, 2013 at 12:23 PM, S Ahmed <[EMAIL PROTECTED]> wrote:
So from what I understand, a single broker will contain all the messages for a given topic (and its partitions). Who decides which broker will own a particular topic? On Sun, Jan 27, 2013 at 3:36 PM, Neha Narkhede <[EMAIL PROTECTED]>wrote:
In 0.8, when a topic is created, we decide how each replica of a partition is mapped to a broker. In general, we try to spread the replicas across all brokers.
On Sun, Jan 27, 2013 at 12:40 PM, S Ahmed <[EMAIL PROTECTED]> wrote:
NEW: Monitor These Apps!
Apache Lucene, Apache Solr and all other Apache Software Foundation project and their respective logos are trademarks of the Apache Software Foundation.
Elasticsearch, Kibana, Logstash, and Beats are trademarks of Elasticsearch BV, registered in the U.S. and in other countries. This site and Sematext Group is in no way affiliated with Elasticsearch BV.
Service operated by Sematext