Können wir bei der Erstellung von Themen bestimmen, welcher Broker der Leader für das Thema ist? Sind die Themen in Kafka ausgewogen? (Unter Berücksichtigung der Themen haben nur eine Partition)Kafka Topic Distribution unter Brokern
0
A
Antwort
1
Kafka tut verwalten diese intern und Sie brauchen sich nicht um diese im Allgemeinen kümmern: http://kafka.apache.org/documentation/#basic_ops_leader_balancing
Wenn Sie ein neues Thema erstellen, wird Kafka einen Makler wählen, basierend auf Belastung. Wenn ein Thema nur eine Partition hat, wird es nur auf einem einzelnen Broker gehostet (plus Follower, wenn Sie mehrere Replikate haben), da eine Partition in Kafka nicht auf mehrere Broker aufgeteilt werden kann.
Trotzdem können Sie die Informationen, die Broker-Host, welches Thema und Sie können auch Themen und Partitionen "verschieben": http://kafka.apache.org/documentation/#basic_ops_cluster_expansion
Verwandte Themen
- 1. Kafka Topic Partition
- 2. Kafka Topic Alias
- 3. Event vs Topic Apache Kafka
- 4. Kafka Topic-pro-Consumer-Konfiguration
- 5. Abrufen und Aktualisieren von Kafka Topic-Konfigurationen über Java-API
- 6. Kafka Topic Partition und Spark Executor Mapping
- 7. Kafka Streams states store backup topic Partitionierungsstrategie
- 8. Kafka Consumer - Topic (s) mit höherer Priorität
- 9. Wie kafka Topic Namen und entsprechende Datensätze in Spark-Streaming-
- 10. Kafka 0.8.2.1 Wie liest man aus __consumer_offsets topic
- 11. Scala - Tweets abonnieren - Kafka Topic und Ingest in HBase
- 12. Logstash kafka topic als Teil von elasticsearch indexname
- 13. Apache Storm: Unterstützung von Topic Wildcards im Kafka-Auslauf
- 14. kafka-topics.sh --- löschen --topic '' testTopic '' funktioniert nicht für kafka V 0.10.1
- 15. Apache Kafka - Consumer Fundamentals
- 16. mit Jmx Monitor Kafka Thema
- 17. Sandcastle Topic Grouping
- 18. Kafka TOPIC_AUTHORIZATION_FAILED
- 19. Apache Kafka: TimeoutException und dann nichts funktioniert
- 20. org.apache.spark.SparkException: Konnte keine Führungsoffsets für Set ([test-topic, 0]) finden
- 21. Flume Distribution
- 22. Kafka gibt NoSuchElementException
- 23. Load Balancing im ActiveMQ-Netzwerk von Brokern
- 24. Wie Implementieren von Failover mit MQTT-Brokern?
- 25. kafka NoClassDefFoundError kafka/Kafka
- 26. Tools zum Sammeln von Metriken von Kafka
- 27. Spark Streaming - Kann ich eine bestimmte Partition von Kafka Topic konsumieren?
- 28. Wie finde ich den Offset-Bereich für eine Topic-Partition in Kafka 0.10?
- 29. Wie bekomme ich alle Nachrichten von kafka topic und zähle sie mit Java? manchmal
- 30. Wie kann ich ein Mock Kafka Topic für Junit-Tests instanziieren?