首页
博客
源码
资源
博客
源码
写文章
发布博客
发布资源
登录
X
kafka
相关资讯
热门
最新
代码人生
01-01 08:00
代码人生
Kafka 消费者API
Kafka 消费者API 由于Kafka在消费过程中有可能会遇到断电宕机等故障,Consumer恢复后,需要从上次消费结束的地方接着消费,因此Kafka需要时刻记录Consumer消费到哪个offset,以便故障恢复后接着消费。 Kafka提供两种方法用来维护offset,
111
代码人生
01-01 08:00
代码人生
Kafka基础(四):Kafka API 实战
Kafka基础(四):Kafka API 实战 1 环境准备 1)启动 zk 和 kafka 集群,在 kafka 集群中打开一个消费者 [atguigu@hadoop102 kafka]$ bin/kafka-console-consumer.sh --zookeeper hadoop102:2181 --topic first 2)导入 pom 依赖 <dependencies&g
247
代码人生
01-01 08:00
代码人生
Kafka基础教程(三):C#使用Kafka消息队列
Kafka基础教程(三):C#使用Kafka消息队列 接上篇Kafka的安装,我安装的Kafka集群地址:192.168.209.133:9092,192.168.209.134:9092,192.168.209.135:9092,所以这里直接使用这个集群来演示 首先创建一个项目,演示采用的是控制台(.net core 3.1),然后使用Nuget安装 Confluent.Kafka 包:
188
代码人生
01-01 08:00
代码人生
kafka生产者 API Demo
kafka生产者 API Demo 添加POM文件 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.11.0.0</version>
95
代码人生
01-01 08:00
代码人生
kafka事务原理、事务API和使用场景(转)
kafka事务原理、事务API和使用场景(转) 原文:https://www.cnblogs.com/wangzhuxing/p/10125437.html 目录 一、事务场景 最简单的需求是producer发的多条消息组成一个事务这些消息需要对consumer同时可见或者同时不可见 。 producer
133
代码人生
01-01 08:00
代码人生
kafka-jstorm实时代码
kafka-jstorm实时代码 package comdoctor.kafkajstrom; import java.util.HashMap; import java.util.Map; import java.util.concurrentTimeUnit; import org.apache.commons.lang.RandomStringUtils; import org.s
101
百科问答
01-01 08:00
百科问答
kafka应用实例(kafka简单的入门案例)
kafka应用实例(kafka简单的入门案例)kafka快速实战与基本原理详解背景Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多副本的(replica),基于zookeeper协 调的分布式消息系统,它的最大的特性就是可以实时地处理大量数据以满足各种需求场景:比如基于hadoop的批处理系统 统、低延迟的实时系统、Storm/Spark流式处理引擎,web/nginx日志、访问日志,消息服务等等
669
百科问答
01-01 08:00
百科问答
kafka参数配置文件详解(elk日志分析系统操作方法)
kafka参数配置文件详解(elk日志分析系统操作方法)Apache Kafka 原理分区副本机制Kafka 有三层结构:Kafka 有多个主题,每个主题有多个分区,每个分区又有多条消息。分区机制:主要解决了单台服务器存储容量有限和单台服务器并发数限制的问题。一个分片的不同副本不能放到同一个 broker 上。当主题数据量非常大的时候,一个服务器存放不了,就将数据分成两个或者多个部分,存放在多台服务器上。每个服务器上的数据,叫做一个分片。分区对于 Ka
74
代码人生
01-01 08:00
代码人生
kafka参数配置文件详解(elk日志分析系统操作方法)
kafka参数配置文件详解(elk日志分析系统操作方法),ApacheKafka原理分区副本机制Kafka有三层结构:Kafka有多个主题,每个主题有多个分区,每个分区又有多条消息。分区机制:主要解决了单台服务器存储容量有限和单台服务器并发数限制的问题。一个分片的不同副本不能放到同一个broker上。当主题数据量非常大的时候,一个服务器存放不了,就将数据分成两个或者多个部分,存放在多台服务器上。每
126
百科问答
01-01 08:00
百科问答
Kafka-Producer的实现细节
Kafka-Producer的实现细节,背景遇到一些线上问题,发现对一些kakfa的配置细节不太了解,通过本文梳理一下认知,一些核心目标:梳理一下Kafka-Client的主要流程梳理一下Kafka-Client的配置,以及他们如何影响kafka的客户端发送梳理一下kafka-Client的metric指标有哪些,如何配置和获取这些指标,以及如何利用这些指标进行观测和排查主要流程作为一个Produ
132
«
1
2
3
4
5
6
7
8
9
10
11
»