内存问题本篇文章介绍Kafka处理大文件出现内存溢出 java.lang.OutOfMemoryError: Direct buffer memory，主要内容包括基础应用、实用技巧、原理机制等方面，希望对大家有所帮助。bin目录下的kafka-run-class.sh中须要配置的参数kafka是由...

Kafka技术专题之「问题分析篇」消息队列服务端出现内存溢出OOM以及相关实战分析系列

主旨内容本篇文章介绍Kafka处理大文件出现内存溢出 java.lang.OutOfMemoryError: Direct buffer memory，主要内容包括基础应用、实用技巧、原理机制等方面，希望对大家有所帮助。broker端配置文件须要配置的参数message.max.bytes : ka...

Kafka流程流转-服务端

kafka分为客户端和服务端，通常我们知道broker是服务端，而生产者和消费者作为客户端。因此在服务端就必定需要解决并发和网络IO的问题。因此不可避免需要用到SocketChannel和ServerSocketChannel，可以看到kafka就使用了ServerSocketChannel,采用N...

【Kafka】-Kafka服务端脚本详解(3)一性能测试脚本

脚本名称脚本用途kafka-producer-perf-test.shkafka生产者性能测试脚本kafka-consumer-perf-test.shkafka消费者性能测试脚本kafka-console-producer.shkafka生产者控制台kafka-console-consumer.s...

【Kafka】-Kafka服务端脚本详解(2)一log,verifiable

脚本名称脚本用途kafka-log-dirs.sh查看指定broker上日志目录使用情况kafka-verifiable-consumer.sh检验kafka消费者kafka-verifiable-producer.sh检验kafka生产者kafka-log-dirs.sh--bootstrap-s...

【Kafka】-Kafka服务端脚本详解(1)-topics

脚本名称脚本用途kafka-topics.shtopic管理脚本connect-distributed.sh连接分布式模式脚本connect-standalone.sh连接单机模式脚本kafka-topics.sh--partitions创建或修改主题的分区数--replication-factor...