在一次项目中,因甲方需要使用kafka消息队列推送数据,所以需要接入kafka,并且kafka的版本是2.11。但是我们项目使用的是Springboot 1.5.7的版本,对应的springboot.kafka.starter有冲突,所以就接入了kafka-client。springboot接入ka ...
分类:
编程语言 时间:
2020-10-18 10:00:08
阅读次数:
18
基本上每个成熟的框架或者工具都有一套内存管理机制 BufferPool 是Kafka 用来管理内存的工具类 BufferPool内存管理包含2个部分,已用空间+可用空间(未申请空间+已申请未使用空间) 的总和代表BufferPool的总量,用totalMemory表示(由buffer.memory配 ...
分类:
其他好文 时间:
2020-10-16 10:35:02
阅读次数:
22
kafka简介及Spring Boot整合kafka
分类:
编程语言 时间:
2020-10-14 19:58:50
阅读次数:
91
在上一章中SpringBoot整合RabbitMQ,已经详细介绍了消息队列的作用,这一种我们直接来学习SpringBoot如何整合kafka发送消息。 kafka简介 kafka是用Scala和Java语言开发的,高吞吐量的分布式消息中间件。高吞吐量使它在大数据领域具有天然的优势,被广泛用来记录日志 ...
分类:
编程语言 时间:
2020-10-13 17:35:42
阅读次数:
33
自 1994 年 PHP诞生 以来, PHP语言经历了许多改进,其中性能是开发人员在评估新版本时考虑的主要标准之一。 之前的版本暂且先不提,咱们可以先来唠唠目前使用的PHP7.3版本,大家都知道 PHP 7 发布的时候号称比 PHP5.6 快两倍,那PHP7.3的性能如何呢? Phoronix 在 ...
分类:
Web程序 时间:
2020-10-10 18:02:20
阅读次数:
52
Receiver Direct offset注意点 ...
分类:
其他好文 时间:
2020-10-06 20:46:36
阅读次数:
26
1.maven依赖 <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>1.8</maven.compiler.source> <maven.co ...
分类:
数据库 时间:
2020-09-24 22:12:38
阅读次数:
88
kafka运行一段时间挂掉 查看日志: 修改./kafka/config/server.properties (修改日志存放位置) log.dirs=/tmp/kafka-logs ...
分类:
其他好文 时间:
2020-09-24 21:01:24
阅读次数:
54
通过简单的python脚本,获取指定group的队列长度
分类:
其他好文 时间:
2020-09-23 23:30:54
阅读次数:
69
Kafka是Apache下的一个子项目,是一个高性能跨语言分布式发布/订阅消息队列系统,吞吐速率非常快,可以作为Hadoop的日志收集。Kafka是一个完全的分布式系统,这一点依赖于Zookeeper的分布式实现。 本文为新手准备,从Kafka的一些术语概念方面去认识Kafka。 Broker Ka ...
分类:
其他好文 时间:
2020-09-18 17:19:41
阅读次数:
37