2017-09-21 3 views
0

J'ai besoin de lire les messages Avro dans le client C# RdKafka. Dans la commande de la console j'utilise cette propriété:RdKafka Avro Consumer

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

Comment puis-je mettre cette propriété dans la configuration du client?

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

Répondre

0

RdKafka is abandoned en faveur de Confluent.Kafka:

Dans le client C#, Avro et registre de schéma ne sont pas officielement encore disponibles, mais il y a d'autres projets dont il fait, comme https://github.com/jakobz/schema-registry-dotnet - voir dans le test pour une utilisation avec bibliothèque Avro - et https://github.com/Judopay/Judo.Kafka/tree/master/src/Judo.Kafka, qui utilisent une bibliothèque de portage microsoft.Hadoop à noyau .net et utiliser https://github.com/Judopay/SchemaRegistryClient pour le client de registre de schéma)

Je travaille sur le soutien Avro comme contributeur de Confluent.Kafka, mais aucune idée quand ce serait fait/offic ialy disponible. Aller au projet github pour avoir plus d'infos/mises à jour;)

+0

J'ai trouvé la bibliothèque SchemaRegistry dans Nuget Manager, est-ce que ça marche avec RdKafka ou Confluent.Kafka? Ou n'y a-t-il aucun moyen d'obtenir Avro par C# Client? – Maxkb24

+0

Je ne connais pas le nuget de registre de schéma - il y a plusieurs librairies opensource (schemaregistry, jacobz, judo.kafka) qui fournissent un peu de support, mais j'ai eu quelques problèmes lors des tests) Si vous êtes autorisé à utiliser une pépite de pré-libération à partir de Soure Appveyor, je pourrais vous en obtenir un, mais nous considérons cela comme un travail en cours, pas officiel Utilisez-vous. Net Framework ou. Net Core? Cela ne fonctionnera que sur .net 45+, .netcoreapp20 et netstandard20, pas netcoreapp1.x ou netstandard 1.x L'un des problèmes que nous allons rencontrer est que la bibliothèque avro en C# n'est pas complète – Treziac