检查下IP地址

1. @KafkaListener(topics = {"${kafka.test.topic}"},groupId = "xiaofeng1")

2. public void consumer(String message) {

3. logger.info("groupId = xiaofeng1, message = " + message);

4. }

先10再10的一个二次迭叠处理

https://blog.csdn.net/maoyuanming0806/article/details/80553632可以参考一下

你可以这样理解，zookeeper和kafka是两个程序。这两个程序启动都有自己的默认端口，zookeeper的默认端口是2181，kafka的默认端口是9092。一台计算机上两个程序的所占用的端口是不能一样的，所以不能重复。9092是kafka的默认端口，写在kafka的配置文件里面的，你看视频里面老师启动kafka的时候指定了配置文件server.properties。

子曰：“三人行，必有我师焉；择其善者而从之，其不善者而改之。”

没有最好，只有合适。

https://github.com/AnAngryMan/KafkaSimpleExample

kafka

kafka Streams 与其他流处理平台的差异在哪里

同一时点，主（leader） partition 只会存在于一个 broker 上，如果改broker 挂掉了，存在于其他 broker
上的从（follwer） partition会通过zookeeper服务提供的竞选机制升级为主（leader）partition。

通常一个 broker 里会存储多个不同 topic 的 partition

零拷贝指的不是省略了内核缓冲区和用户缓冲区的交互吗。先是从磁盘到内核缓冲区，再从内核缓冲区直接到网卡缓冲区。整个过程是操作系统来完成的吧

应用程序不能直接操作内核态，需要请求操作系统的系统调用来执行

不相同。一个topic包含多个partition，topic携带的produer的消息经过一定的算法，分配到多个partition上的message上面，它们组合在一起构成一条完整的消息

数据流的特性就是有序。数据流如果时基本数据类型，基本数据类型时自动包装，它会自动序列化。自定义的数据类型，需要手动序列化，发送方序列化之后传递数据流，接收方反序列化就可以解析。如果没有序列化，发送的时二进制代码，不易解析

git地址时什么？

难道是kafka2.0新特性？

没看到源码地址在哪里呀？

在课程介绍不是有源码了？我猜是你内容格式哪里不对，spring识别不了吧

好好学习，多多思考

估计你是下错包了，下载 apache-zookeeper-3.5.5-bin 再试一下。

没有。

需要注解

@Slf4j

这里有一张差不多的图片，多了位移和消息位移的概念

根据意思来看，是不是TOPIC的名称不存在？

mac上的iterm2

你这个问题我也没遇到过。我是一次就过的

这是我在网上找到的，希望对你能帮助。

Spring Boot 的MVC默认配置中使用的ViewResolver为ContentNegotiatingViewResolver，该视图解析器的功能是根据要请求的文档类型，来查找不同的视图以返回对应格式的文档。请求的文档类型要可以从请求头中的接受中获取，也可以通过URI后缀名得到，如/login.html即为请求HTML格式的文档，这两种方式分别对应着两种不同的策略（策略），默认为根据URI后缀名。

topic是你逻辑上的一个概念，partition是真正物理上的存储。在kafka中topic是你能直接操作的东西，通过它你可以获取到该topic下所有的数据。