Я использую Confluent.Kafka
string kafkaEndpoint = "127.0.0.1:9092";
string kafkaTopic = "testtopic";
var producerConfig = new Dictionary<string, object> { { "bootstrap.servers", kafkaEndpoint } };
using (var producer = new Producer<Null, string>(producerConfig, null, new StringSerializer(Encoding.UTF8)))
{
// Send 10 messages to the topic
for (int i = 0; i < 10; i++)
{
var message = $"Event {i}";
var result = producer.ProduceAsync(kafkaTopic, null, message).GetAwaiter().GetResult();
Console.WriteLine($"Event {i} sent on Partition: {result.Partition} with Offset: {result.Offset}");
}
}
Я получаю следующую ошибку времени компиляции:
Producer.ProduceAsync (TopicPartition, Message) 'недоступен из-за егоуровень защиты
Использование ProducerBuilder
, например:
var result = producer.ProduceAsync(kafkaTopic, new Message<Null, MyClass>{ Value = myObject}).GetAwaiter().GetResult();
показывает ошибку:
Cannot convert from 'Confluent.Kafka.Message<Confluent.Kafka.Null, MyClass>' to 'Confluent.Kafka.Message<Confluent.Kafka.Null, string>