So erstellen Sie ein Thema in Apache kafka mit Python

10

Bisher habe ich keinen Python-Client gesehen, der die Erstellung eines Themas explizit implementiert, ohne die Konfigurationsoption zu verwenden, um die Themen automatisch zu erstellen.

    
jpgerek 24.09.2014, 16:03
quelle

5 Antworten

2

Es scheint, dass es keine kafka Server API gibt, um ein Thema zu erstellen, so dass Sie die automatische Erstellung des Befehls oder des Befehlszeilenwerkzeugs verwenden müssen:

%Vor%     
jpgerek 25.09.2014 11:50
quelle
1

Wie Sie sehen, können Sie Folgendes verwenden, um sicherzustellen, dass Ihr Thema bereits existiert (ich nehme an, Sie verwenden das folgende kafka python Umsetzung):

%Vor%     
Salvador Dali 26.01.2015 05:09
quelle
0

Es ist schon zu spät. Ich weiß nichts über einen Befehl zur expliziten Erstellung der Themen, aber der folgende erstellt und fügt die Nachrichten hinzu.

Ich habe einen Python Kafka Producer erstellt:

%Vor%

In der Liste der Kafka-Themen war xyz vorher nicht vorhanden. Wenn ich die obige Methode gemacht habe, hat der Python-kafka-Client es erstellt und die Nachrichten hinzugefügt.

    
wonder 20.06.2017 08:28
quelle
0

Die AdminClient-API, die für die programmatische Themenerstellung und -konfiguration benötigt wird, wurde gerade in Kafka 0.11 (ursprünglich für Java) hinzugefügt.

Siehe Ссылка

Es wird erwartet, dass Nicht-Java-Clientbibliotheken diese Funktionalität im Laufe der Zeit hinzufügen. Erkundigen Sie sich bei dem Autor des Kafka Python-Clients, den Sie verwenden (es gibt mehrere), ob und wann KIP-4 Admin-Protokoll-Unterstützung in der API sein wird

Siehe Ссылка

    
Hans Jespersen 21.06.2017 06:20
quelle
0
%Vor%     
user2468325 10.03.2018 17:42
quelle

Tags und Links

Django: Verwenden von Annotate, Count und Distinct in einem Queryset Berücksichtigen gcc's __float128 Gleitkommazahlen den aktuellen Rundungsmodus?