• 每天晒白牙
    2019-08-31
    这篇加餐很及时,正好在读kafka的源码,感谢老师
    
     4
  • 姜戈
    2019-08-31
    收藏了,刚好消息中间件学习,阅读Kafka源码,太及时了
    
     1
  • Hello world
    2019-12-12
    老师,想问您一个问题,producer是直连的kafka , kafka集群下线一台机器后(分片也已经迁移到其他服务器),producer就会报错一直连不上那台服务器,重启也会这样,现在我怀疑是producer拿了broker缓存的metadata数据,broker缓存的metadata数据可能会很长时间才会更新。现在有一个问题,kafka是否有一个接口可以去强制刷新broker的缓存呢

    作者回复: 如果出现这种情况,producer应该会自动刷新元数据的。不妨试试KafkaProducer.partitionsFor方法来强制刷新下

    
    
  • 兔2🐰🍃
    2019-11-13
    按照上面步骤搭建,请问要安装ZooKeeper么?

    作者回复: Kafka自带了ZooKeeper,不过你依然需要首先启动ZooKeeper

    
    
  • 懒懒的龟
    2019-11-12
    kafka 启动报错,报请求偏移量2但是我们只有0到0范围内的日志段,这个可能是什么原因

    作者回复: 有具体的日志看看吗? 可能的原因是你的日志被截断了,之前保存的数据都删除了

     2
    
  • Geek_a6f5ee
    2019-11-04
    有没有好的python语言的kafka开源项目

    作者回复: https://github.com/confluentinc/confluent-kafka-python

    
    
  • james
    2019-09-26
    请问线上kafka数据可以迁移到线下kafka吗 也就是不同kafka直接数据迁移 复制文件的方式可否呢

    作者回复: 嗯,就我个人而言,这属于生僻的用法,但不是不能用,只是把它当做最后的选项吧。尽量还是按照Kafka推荐的方式来做迁移

    
    
  • 见哥哥
    2019-09-24
    输入gradle后,等了很久,然后报错了,有遇到的吗?

    作者回复: 可能是被墙了吧。。。

     1
    
  • dengy
    2019-09-20
    老师,最近发现由kafka topic+偏移量+分区组成的ID有重复,es使用这些重复ID的时候,会只保留最新的一条。请问如何使用kafka参数组成一个唯一的ID

    作者回复: 有重复说明是否存在重复消费的问题,本身就值得好好查一下。如果一定要唯一ID,引入UUID就可以了

    
    
  • sonald
    2019-09-15
    跑./gradlew clean releaseTarGz其实会自动下载gradle吧。之前安装gradle似乎没有必要?

    作者回复: 推荐还是使用Gradle的wrapper

    
    
  • godtrue
    2019-09-15
    课后思考及问题
    你觉得学习 Kafka 或者任何一种技术,最重要的是什么?
    学习是个持续的过程,经验和外部帮助固然重要,但最关键的,还是自己要付出努力,持之以恒。
    还是那句话:Stay focused and work hard!
    不怕不占先,就怕缠的粘。基础好脑子聪明这些条件有最好,否则除了Stay focused and work hard别无他法。
    
    
  • 墙角儿的花
    2019-09-11
    老师 对于im服务器集群,客户端的socket均布在各个服务器,目标socket不在同一个服务器上时,服务器间需要转发消息,这个场景需要低延迟无需持久化,服务器间用redis的发布订阅,因其走内存较快,即使断电还可以走库。im服务器和入库服务间用其他mq解耦,因为这个环节需要持久化,所以选rocketmq或kafka,但kafka会延迟批量发布消息 所以选rocketmq,这两个环节的mq选型可行吗。
    
    
  • 曾轼麟
    2019-09-11
    我觉得最重要的是两个,坚持和热情,老师还有一本书也挺好的《apache kafka源码剖析》
    
    
  • 每天晒白牙
    2019-09-10
    周六日写的Kafka服务端之网络层的源码分析
    https://mp.weixin.qq.com/s/-VzDU0V8J2guNXwhiBEEyg

    作者回复: 赞~

    
    
  • double
    2019-09-10
    老师,partition与replication是怎么分配到broker上的

    作者回复: 分区是个虚拟概念,分区下的副本才是broker实际分配的对象。默认情况下,你大致可以认为创建topic时副本是按照round-robin策略分配在不同broker上的。

     1
    
  • Allen Lei
    2019-09-02
    我觉得最重要的是要知道为什么这门技术会存在,解决了什么问题,最重要的是思想
    
    
  • 南山
    2019-09-01
    1.学习实现原理,经典实现的技术细节,编程思想,架构设计
    2.坚持住,形成体系
    3.实践,实践,实践
    
    
  • 开水
    2019-08-31
    太及时了,昨天刚留言,今天就分享了。赞一个👍
    
    
  • 许童童
    2019-08-31
    老师真是太牛了,向老师学习。
    
    
  • 锦
    2019-08-31
    Scala语言需要学习到什么程度才能读懂源码呢?

    作者回复: 不需要了解太高深,就当是个better java就行。Kafka里面也没有用到Scala很高大上的语法特性

    
    
我们在线,来聊聊吧