我需要阅读Kafka客户端的avro消息。在控制台命令中，我使用以下属性：
--属性schema.registry.url=http://localhost:8081
如何将此属性放入客户端的配置中？
var config = new Config() { GroupId = "kafkaUser",
EnableAutoCommit = enableAutoCommit,
StatisticsInterval = TimeSpan.FromSeconds(60),
["auto.offset.reset"] = "smallest",
["?"] = "http://localhost:8081" };
1条答案
按热度按时间txu3uszq1#
Kafka是官方合流网络Kafka的替代品，曾经被认为是废弃的
他们现在成了同一个项目
在c#client中，还有其他项目，如https://github.com/jakobz/schema-registry-dotnet -有关avro库的用法，请参见测试中的-和https://github.com/judopay/judo.kafka/tree/master/src/judo.kafka,其中使用了一个将microsoft.hadoop库移植到.net内核并使用https://github.com/judopay/schemaregistryclient 架构注册表客户端）