Kafka 安装部署及使用(单节点/集群)

Kafka 安装部署及使用(单节点/集群)

版权声明:本文为博主原创文章,未经博主允许不得转载。 https://blog.csdn.net/HG_Harvey/article/details/79174104 导读:       本篇博客...
如何把一个运行完好的Kafka搞崩溃

如何把一个运行完好的Kafka搞崩溃

版权声明:本文为博主原创文章,未经博主朱小厮允许不得转载。 https://blog.csdn.net/u013256816/article/details/82804525 欢迎支持《Rabbit...
故障:Kafka异步发送致使所有相关线程阻塞

故障:Kafka异步发送致使所有相关线程阻塞

这个故障在我们前段时间线上服务碰到过,具体的问题描述跟KAFKA-1415里提及的完全一样。 简单概括就是,正常情况下,使用kafka异步producer.send()发送消息时,会在...
Flink从kafka中消费数据–解析

Flink从kafka中消费数据–解析

一、情况介绍: 基于scala语言的Flink从kafka中消费数据,然后使用protobuf解析,当然默认是使用string解析的,此处需要指定接收的数据格式 package cetc.kak...
spring boot kafka 支持批量操作

spring boot kafka 支持批量操作

版权声明:本文为博主原创文章,转载请附上博文链接,谢谢! https://blog.csdn.net/qq_30062125/article/details/83095290 前言 最近有个项...
kafka 中的 内网和公网IP配置

kafka 中的 内网和公网IP配置

版权声明:本文为博主原创文章,转载请 注上 http://blog.csdn.net/wzhwei1987 https://blog.csdn.net/wzhwei1987/article/details/83388095 当使用阿...
kafka 启动的时候报错

kafka 启动的时候报错

1. kafka 启动的时候报错了,生成了一个类似这样的日志文件hs_err_pid4301.log 主要原因原因:kafka启动脚本kafka-server-start.sh中指定了kafka启动...
Flume介绍以及实战应用

Flume介绍以及实战应用

1.1 Flume介绍 前言: 在一个完整的大数据处理系统中,除了hdfs+mapreduce+hive组成分析系统的核心之外,还需要数据采集、结果数据导出、任务调度等不可或缺的辅助系...