大道独行

大道独行 查看完整档案

上海编辑  |  填写毕业院校  |  填写所在公司/组织 zlikun.com 编辑
编辑

眼界决定高度,格局决定成就 ~

个人动态

大道独行 提出了问题 · 2020-03-17

两个子域如何组建一个局域网?

本人非运维,所以对组网不甚了解,所以这可能是个低级问题。

情况是这样的,电信光纤上接了一个交换机,上面分别连有一台PC,一个路由器,路由器开启无线网络,无线网络上有几个设备,PC和这几个设备分别处于两段网络(子网)下面,分别是 192.168.0.x192.168.1.x 上面,如何设置可以使这两个网段之间可以通信,说白了就是组成一个更大的局域网,子网掩码应该是 225.225.0.0 这样的。

表述的未必准确,但意思大致应该清楚,请懂的兄弟指点一下,谢谢。

关注 1 回答 0

大道独行 回答了问题 · 2019-07-29

解决消息队列中吞吐量和处理速度这两个指标的困惑

不能,一般来说kafka更多的是使用吞吐量这个指标,一段时间里面处理的消息总数即为吞吐量,但kafka是可以批量处理的,批量模式下一次处理的速度未必快,但整体吞吐量却会很高。
当然这里不要钻牛角尖,如果根据吞吐量来计算处理速度,那两者确实等价,一批消息(1000),处理1秒钟,如果认为一条消息处理耗时1毫秒,那吞吐量跟处理速度本质上没差别。
实际上kafka通常不讨论处理速度这个指标,一般都讲它的吞吐量(务实)。

关注 3 回答 1

大道独行 回答了问题 · 2019-07-29

kafka的配置,是在代码客户端设置,还是在kafka端设置?

不是一回事,kafka服务端的producer.properties配置文件并不是直接给kafka服务使用的,而是其它工具(bin目录下还有一些其它工具)使用的,这些工具本质上也是一个客户端,所以两边并不会冲突

关注 3 回答 1

大道独行 回答了问题 · 2019-07-29

新版kafka消费者、生产者配置为何使用bootstrap-servers而不是zookeeper服务器地址?

个人理解,新版消费者通过brokers而不是zookeeper是因为对消费端而言zookeeper应该是透明的,消费端需要的是kafka里的数据而zookeeper是kafka集群内部需要的,不应被暴露给外部,当然消费者获取broker信息本质仍是通过zookeeper来获取,只是这一过程被kafka隐藏起来了,从语义上隐藏了zookeeper服务

关注 5 回答 2

大道独行 回答了问题 · 2019-07-29

kafka中10个消费者消费10个分区与11个消费者消费20个分区有什么区别,哪一种更快?

10个消费者10个分区,那么10个消费者都是有效的,一个消费者对应一个分区,可以当作并发为10,而11个消费者20个分区,分区数大于消费者数量,所以有的消费者会消费多个分区,但不管怎么说11个消费者都是有效的,并发为11,理论上并发11肯定快于10的

关注 2 回答 1

大道独行 回答了问题 · 2019-07-29

spring cloud bus 配置服务端无法连接kafka

Kafka服务(broker)无法连接,检查一下Kafka是否允许外部主机访问

advertised.listeners=PLAINTEXT://你的Kafka主机IP:9092

关注 3 回答 2

大道独行 回答了问题 · 2019-07-29

调用Springmvc接口发送kafka,如何设计接口返回值

异步发送肯定不能同步返回,否则整体视为同步代码,失去异步的意义,异步一般会通过回调的方式来执行相应的逻辑,Kafka异步发送会异步成功或失败回调,在回调中处理业务逻辑,而调用方(客户端)也必须支持异步处理。

关注 3 回答 2

大道独行 回答了问题 · 2019-07-29

解决Kafka消费者,如何消费最新的消息?

可以试试配置默认消费偏移量为最新 spring.kafka.consumer.auto-offset-reset=latest 不过这个配置理论上只对第一次消费(此时没有偏移量,按配置的策略来)有效,不过可以变通的方式来实现,如果每次启动时 group.id 不同的话可以实现,当然这种方式有点重

关注 4 回答 4

大道独行 回答了问题 · 2019-07-29

怎么让kafka客户端只消费启动之后收到的消息?

可以试试配置默认消费偏移量为最新 spring.kafka.consumer.auto-offset-reset=latest 不过这个配置理论上只对第一次消费(此时没有偏移量,按配置的策略来)有效,不过可以变通的方式来实现,如果每次启动时 group.id 不同的话可以实现,当然这种方式有点重

关注 3 回答 2

大道独行 回答了问题 · 2019-07-29

【在设计消息队列时,重要业务会对消息进行副本处理】这个具体操作是怎么进行的呢?

副本的作用是用冗余来提高可用性,存在副本的条件下,当一个节点宕机或数据损坏时,对使用方而言数据仍是完整可用的,以Kafka为例,消费数据只是记录偏移量,不存在副本不消费一说

关注 2 回答 1

认证与成就

  • 获得 37 次点赞
  • 获得 45 枚徽章 获得 3 枚金徽章, 获得 17 枚银徽章, 获得 25 枚铜徽章

擅长技能
编辑

开源项目 & 著作
编辑

(゚∀゚ )
暂时没有

注册于 2015-10-19
个人主页被 932 人浏览