• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

c# rdkafka 设置偏移量(offset)

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

参考资料:

  librdkafka: 如何设置Kafka消费者订阅消息的起始偏移位置

领导要求kafka消费者端消费最新的数据。

不知道怎么设置偏移量,查了资料。

用惯了封装好的东西,都不知道怎么设置了,看了源代码以及参考资料,才知道自己动手写。

                var config = new Config
                {
                    GroupId = UtilityConfig._groupId,
                    EnableAutoCommit = true,
                    StatisticsInterval = TimeSpan.FromSeconds(6),
                    ["auto.offset.reset"] = "lastest" //设置获取最新的消息,要设置什么去官方文档找,直接通过key-value方式设置即可
                };
                using (var consumer = new EventConsumer(config, UtilityConfig._brokerlist))
                {
                     //代码逻辑

config部分源码

 

    public string this[string name]
    {
      set
      {
        this.handle.Set(name, value);
      }
      get
      {
        return this.handle.Get(name);
      }
    }

    public string GroupId
    {
      set
      {
        this["group.id"] = value;
      }
      get
      {
        return this["group.id"];
      }
    }

    public bool EnableAutoCommit
    {
      set
      {
        this["enable.auto.commit"] = value ? "true" : "false";
      }
      get
      {
        return this["enable.auto.commit"] == "true";
      }
    }

 

 

 

从源码可以看出config里面的EnableAutoCommit属性是自己封装的,所以要设置什么属性就自己通过索引器设置。

 

大家千万不要想着偷懒呐。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
C#Word操作2发布时间:2022-07-13
下一篇:
C#基础备忘录发布时间:2022-07-13
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap