Ошибки при обновлении сообщений Confluent.Kafka Unit test. NET Core - PullRequest
Новая
       6

Ошибки при обновлении сообщений Confluent.Kafka Unit test. NET Core

1 голос
/ 08 февраля 2020 
_failedResult = new Message<string, string>(Consts.Topic, Consts.Partition, Consts.Offset, Consts.Key, It.IsAny<string>(), default(Timestamp), new Error(ErrorCode.Local_MsgTimedOut, MsgTimeoutReason));

У меня проблемы с обновлением до последней версии Kafka, поскольку мои модульные тесты используют старый формат сообщений. Я не могу найти список документации, как правильно отформатировать сообщение. Любая помощь будет оценена.

Спасибо

1 Ответ

0 голосов
/ 31 марта 2020

Вы можете увидеть формат сообщения на текущем стабильном v1.3.0 в confluent-kafka-dotnet:

https://github.com/confluentinc/confluent-kafka-dotnet/blob/v1.3.0/src/Confluent.Kafka/Message.cs

Вы производите следующим образом: 

var message = new SomeDto();

var dr = await _producer.ProduceAsync(
    "topic-name",
    new Message<Null, SomeDto>
    {
        Value = message
    },
    cancellationToken);

Данные, включенные в ваше сообщение, такие как Topic, Partition, больше не являются частью сообщения (они являются частью конфигурации или метода источника)

...