2017-09-21 1 views
0

Ich muss Avro Nachrichten im C# RdKafka Client lesen. In dem Konsolenbefehl verwende ich diese Eigenschaft:RdKafka Avro Consumer

--Eigentum schema.registry.url = http://localhost:8081

Wie ich diese Eigenschaft in der Konfiguration in dem Client setzen kann?

var config = new Config() { GroupId = "kafkaUser", 
           EnableAutoCommit = enableAutoCommit, 
           StatisticsInterval = TimeSpan.FromSeconds(60), 
           ["auto.offset.reset"] = "smallest", 
           ["?"] = "http://localhost:8081" }; 

Antwort

0

RdKafka is abandoned für Confluent.Kafka:

In C# Client, Avro und Schema Registry nicht offiziell noch verfügbar ist, aber es gibt anderes Projekt, das es funktioniert, wie https://github.com/jakobz/schema-registry-dotnet - siehe im Test für die Verwendung mit Avro Bibliothek - und https://github.com/Judopay/Judo.Kafka/tree/master/src/Judo.Kafka, die eine portage von microsoft.Hadoop Bibliothek .net Kern verwenden und https://github.com/Judopay/SchemaRegistryClient für Schema Registry-Client)

ich arbeite auf der Bereitstellung von Avro Unterstützung als Beitrag von Confluent.Kafka, aber keine Ahnung, wenn es wäre getan/offic gerade verfügbar. Gehe zu Github-Projekt, um mehr Infos/Updates zu haben;)

+0

Ich habe SchemaRegistry-Bibliothek in Nuget Manager gefunden, funktioniert es mit RdKafka oder Confluent.Kafka? Oder gibt es keine Möglichkeit, Avro von C# Client zu bekommen? – Maxkb24

+0

Ich kenne das Schema Registry nugget nicht - es gibt mehrere Open Source-Bibliotheken (Schemaregistry, jacobz, judo.kafka), die Unterstützung bieten, aber ich hatte einige Probleme beim Testen von ihnen) Wenn Sie ein Prerelease-nugget verwenden von mir kann ich Ihnen eine davon bringen, aber betrachten Sie dies als eine laufende Arbeit, nicht offiziell Verwenden Sie. NET-Framework oder. NET-Kern? Dies funktioniert nur auf .net 45+, .netcoreapp20 und netstandard20, nicht netcoreapp1.x oder netstandard 1.x Eines der Probleme, mit denen wir konfrontiert werden, ist, dass Avro-Bibliothek in C# nicht abgeschlossen sind – Treziac

Verwandte Themen