升级confluent.kafka单元测试消息.net核心时出错

8wigbo56 于 2021-06-05 发布在 Kafka

关注(0)|答案(1)|浏览(334)

_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时遇到了问题，因为我的单元测试使用的是旧的消息格式。我似乎找不到列出如何正确格式化消息的文档。任何帮助都将不胜感激。
谢谢

apache-kafka .net confluent-platform

来源：https://stackoverflow.com/questions/60128232/errors-upgrading-confluent-kafka-unit-test-messages-net-core

1条答案

按热度按时间

5vf7fwbs1#

你可以看到当前稳定的消息格式 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 不再是消息的一部分（它们是producer config或producer方法的一部分）

赞(0）回复(0）举报 2021-06-05

我来回答

升级confluent.kafka单元测试消息.net核心时出错

1条答案

相关问题

热门标签

最新问答