Мне удалось воспроизвести небольшое решение только с этим кодом в program.cs
, я могу построить решение и увидеть метод расширения AsSyncOverAsync
, который находится в пространстве имен Confluent.Kafka.SyncOverAsync
.
class Program
{
static void Main(string[] args)
{
IEnumerable<KeyValuePair<string, string>> consumerConfig = new List<KeyValuePair<string, string>>();
using (var schemaRegistry = new CachedSchemaRegistryClient(new SchemaRegistryConfig { }))
using (var consumer =
new Confluent.Kafka.ConsumerBuilder<string, GenericRecord>(consumerConfig)
.SetValueDeserializer(new AvroDeserializer<GenericRecord>(schemaRegistry).AsSyncOverAsync())
.Build()) { }
}
}
Это *.csproj
файл:
<Project Sdk="Microsoft.NET.Sdk">
<PropertyGroup>
<OutputType>Exe</OutputType>
<TargetFramework>netcoreapp3.1</TargetFramework>
</PropertyGroup>
<ItemGroup>
<PackageReference Include="Confluent.Kafka" Version="1.4.0" />
<PackageReference Include="Confluent.SchemaRegistry.Serdes.Avro" Version="1.4.0" />
</ItemGroup>
</Project>
Похоже, вам не хватает пакета Confluent.SchemaRegistry.Serdes.Avro
, поэтому попробуйте вручную установить их оба из Nuget.