Ich stelle einen Kafka-Cluster auf drei Hosts bereit. Stellen Sie die Benutzer auf denselben Hosts bereit. Wie ich den Consumer die Partitionen des nächsten Brokers konsumieren lassen soll. Zum Beispiel host a
Consumer verbrauchen nur die Partitionen, die zu host a
gehören.Wie Kafka-Verbraucher wählen, nächsten Broker zu konsumieren?
0
A
Antwort
2
Kafka funktioniert nicht so. Die Clients stellen eine Verbindung zu allen drei Brokern her und produzieren und konsumieren von allen drei Brokern parallel, basierend darauf, welche Knoten derzeit für jede Topic-Partition führend sind.
Verwandte Themen
- 1. jquery am nächsten() Wählen
- 2. wie Meteor API-Aufruf zu konsumieren
- 3. Wie Remoting in IronRuby zu konsumieren
- 4. Routing zu virtuellen Zielen innerhalb ActiveMQ Broker
- 5. Kafka Consumer nicht konsumieren
- 6. "Korrekte" Art, nächsten Sequenzwert in HSQLDB 2.0.0-rc8 zu wählen
- 7. Kafka Consumer keine Daten konsumieren
- 8. Regex, wählen Sie am nächsten Spiel
- 9. Ruby on Rails nächsten 3 Monate wählen
- 10. mysql wählen am nächsten Tag von heute
- 11. jQuery wählen Sie alle Kinder der nächsten
- 12. Nicht zu Kafka Broker zu produzieren java.nio.BufferUnderflowException
- 13. Wie Nachrichten in mqtt behalten, wenn der Moskito-Broker ausfällt?
- 14. Wie man Webpack Dateien konsumieren
- 15. Wie konsumieren Webservice in Javascript
- 16. Beste Methode, um APIs zu konsumieren
- 17. Einen HTTP-Stream konsumieren, ohne jeweils ein Byte zu lesen
- 18. Verwenden von Guzzle, um SOAP zu konsumieren
- 19. Gupshup konsumieren Beitrag zu erstellen Einbettungsformular
- 20. Wie zu wählen, was
- 21. Aktivieren SQL Server Broker zu langer Zeit
- 22. Visual Studio 2008: Wie Web Service zu konsumieren oder aufzurufen?
- 23. Wie Sie eine RichTextBox stoppen, um Tastengesten zu konsumieren
- 24. Wie sichere OData-Dienst in Angular JS zu konsumieren
- 25. Wie ein FixedDocument von einem Backgroud-Thread zu konsumieren?
- 26. Wie ein PHP-Web-Service in Java zu konsumieren
- 27. Wie diese JSON-Struktur über Retrofit 2 zu konsumieren?
- 28. Wie Web API von Asp.net Web API-Anwendung zu konsumieren
- 29. Sellerie keine Verbindung zu Redis Broker (Django)
- 30. Paho MQTT Verbindung zu MQXR Broker