- 学堂
- 博客
- 论坛
- 开发服务
- 开发工具
- 直播
- 视频
- 用户
- 一周
- 一个月
- 三个月
-
创建Kafka角色
权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。在指定Topic的“权限”列，勾选“Kafka消费者权限”。在“配置资源权限”的表格中选择“待操作集群的名称 > Kafka > Kafka Topic生产和消费权限”。在指定Top
-
Kafka详解
org/confluence/display/KAFKA/Clients Kafka API简单易用，日志存储之利器。Storm和Kafka的对接：KafkaSpoutStrom从Kafka中读取数据，本质：实现一个Storm中的Spout，来读取Kafka中的数据；这个Spout，可以称为Kafka Spout。支持两种类型的Spout：1
-
kafka搭建
1、上传并解压kafka [root@win1 soft]# tar -zxvf kafka_2.11-2.1.0.tgz 2、创建logfile文件夹 [root@win1 kafka_2.11-2.1.0]# mkdir -p /hadoop/soft/kafka_2.11-2
-
kafka的Docker镜像使用说明(wurstmeister/kafka)
exec kafka-docker_kafka_2 \ kafka-console-consumer.sh \ --topic topic001 \ --bootstrap-server kafka-docker_kafka_1:9092,kafka-docker_kafka_2:9092
-
Kafka offset清理
sh kafka-mirror-maker.sh kafka-topics.sh kafka-console-producer.sh kafka-preferred-replica-election.sh kafka-verifiable-consumer
-
看完这篇Kafka，你也许就会了Kafka
场景 消费形式 kafka基础架构 Record 、Topic、Broker、leader、follower 分区&日志 生产者与消费者 写入和读出的性能 Kafka环境搭建 & Topic管理： kafka和zookeeper之间的关系
-
Kafka中的offset总结
og.flush.offset.checkpoint.interval.ms配置，默认值60000，即60s。Kafka在启动时会检查文件的完整性，如果没有.kafka_cleanshutdown这个文件，就会进入一个recover逻辑，recover就是从此文件中的offset
-
Kafka实战(二)-Kafka消息模型核心概念
nce是Kafka消费者端实现高可用的重要手段。 9 为什么Kafka不像MySQL允许追随者副本对外提供读服务？ 不从follower读几个原因：1，kafka的分区已经让读是从多个broker读从而负载均衡，不是MySQL的主从，压力都在主上；2，kafka保存的数据
-
Kafka修改配置详解
Kafka修改配置有两个命令：kafka-topics.sh和kafka-configs.sh。kafka-topics.sh主要是修改单个topic的配置，支持修改的配置参数见附录一；kafka-configs.sh支持修改topic、broker、user和client级别的
-
Spark 操作 kafka
利用Receiver接收数据，2.直接从kafka读取数据。 在spark1.3之后，引入了Direct方式。不同于Receiver的方式，Direct方式没有receiver这一层，其会周期性的获取Kafka中每个topic的每个partition中的最新offsets，之后根据设定的max
-
kafka 的架构
讲一下kafka 的架构 一个典型的Kafka集群中包含若干Producer，若干broker，若干Consumer Group，以及一个Zookeeper集群。Kafka通过Zookeeper管理集群配置，选举leader，以及在Consumer Group发生变化时进行r
-
Springboot2.0整合Kafka，从Kafka并发、批量获取数据
Kafka安装 Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据。 这种动作（网页浏览，搜索和其他用户的行动）是在现代网络上的许多社会功能的一个关键因素。
-
Apache Kafka-初体验Kafka(03)-Centos7下搭建kafka集群
概述 对于kafka来说，一个单独的broker意味着kafka集群中只有一个节点。要想增加kafka集群中的节点数量，只需要多启动几个broker实例即可。 单个节点的安装： Kafka-初体验Kafka(02)-Centos7下搭建单节点kafka_2.11‐1.1
-
Kafka连接工具与监控工具
EFAK依赖于zookeeper方式启动的kafka https://github.com/smartloli/kafka-eagle-bin/blob/master/efak-web-3.0.2-bin.tar.gz tar -zxvf kafka-eagle-bin-3.0.1
-
Kafka分区未同步
一、 节点故障或磁盘下线1. Kafka节点服务异常通过FusionInsight Manager页面，选择“集群->Kafka”，查看当前Kafka集群当前状态，状态是否是良好；如果状态不是良好，说明Kafka服务异常。2. 磁盘下线通过FusionInsight
-
使用Kafka客户端
工具查看帮助并使用。./kafka-console-consumer.sh：Kafka消息读取工具./kafka-console-producer.sh：Kafka消息发布工具./kafka-topics.sh：Kafka Topic管理工具命令具体使用方法可参考《应用开发指南》
-
本地环境消费开源kafka，将数据写入mrs kafka
生产者代码：报错情况：
-
Kafka删除Topic
删除数据目录中的数据 1. 登录manager页面，查看kafka的服务配置log.dirs，查看kafka对应的数据目录，默认情况下的保存目录为：/srv/BigData/kafka/data*/kafka-logs2. 登录每一个kafka节点，删除每一个数据目录下面每个topicname对应的分区目录：cd
-
Kafka快速入门系列(13) | Flume对接Kafka
本篇博主带来的是Flume对接Kafka。 目录 1. Kafka与Flume比较2. Flume与kafka集成 1. Kafka与Flume比较 在企业中必须要清楚流式数据采集框架flume和kafka的定位是什么： 1. flume：cloudera公司研发
-
Kafka快速入门系列(1) | Kafka的简单介绍(一文令你快速了解Kafka)
消息队列内部实现原理2 为什么需要消息队列 3. 什么是Kafka4. Kafka架构5. Kafka的好处6. 分布式的发布与订阅系统7. kafka的主要应用场景 1. Kafka的定义 Kafka是一个分布式的基于发布/订阅模式的消息队列，主要应用于大数据实时处理领域。
