• Golang:将日志以Json格式输出到Kafka

    在上一篇文章中我实现了一个支持Debug、Info、Error等多个级别的日志库,并将日志写到了磁盘文件中,代码比较简单,适合练手。有兴趣的可以通过这个链接前往:https://gith...
    Go   2022.05.17 07:48
  • 聊聊如何实现一个带幂等模板的Kafka消费者

    前言 不知道大家有没有这样的体验,你跟你团队的成员,宣导一些开发时注意事项,比如在使用消息队列时,在消费端处理消息时,需根据业务场景,考虑一下幂等。后面走查代码...
    JAVA   2022.05.24 09:38
  • Kafka 消费者解析

    一、消费者相关概念 1.1 消费组&消费者 消费者: 消费者从订阅的主题消费消息,消费消息的偏移量保存在Kafka的名字是__consumer_offsets的主题中 消费者还可以将⾃⼰的偏移量存储到Zookeeper,需要设置offset.storage=zookeeper 推荐使⽤Kafka存储 ...
    Kafka 消息中间件 kafka   2022-05-28 19:21