1391
    推荐
    254k
    浏览
    kafka入门介绍
    Kafka作为一个分布式的流平台,这到底意味着什么?我们认为,一个流处理平台具有三个关键能力:1. 发布和订阅消息(流),在这方面,它类似于一个消息队列或企业消息系统。2. 以容错(故障转移)的方式存储消息(流)。3. 在消息流发生时处理它们。 什么是kafka的优势?它主要应用于2大类应用:1....
     半兽人 发布于7年前
    91
    推荐
    252k
    浏览
    kafka安装和启动
    kafka安装和启动kafka的背景知识已经讲了很多了,让我们现在开始实践吧,假设你现在没有`Kafka`和`ZooKeeper`环境。 Step 1: 下载代码[下载](https://www.orchome.com/66)并且解压它。 tar -xzf kafka_2.13-3.0.0....
     半兽人 发布于6年前
    59
    推荐
    133k
    浏览
    Apache Kafka下载
    你可以登录Apache kafka 官方下载。https://kafka.apache.org/downloads.html-------- 注意:别下成源文件了!带`src`的是源文件,如:Source download: kafka-3.0.0-src.tgz (asc, sha512) ...
     半兽人 发布于6年前
    238
    推荐
    121k
    浏览
    Kafka的使用场景
    下面是一些关于`Apache kafka`非常流行的使用场景。这些领域的概述,可查看[博客文章](https://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-abo...
     半兽人 发布于5年前
    455
    推荐
    120k
    浏览
    kafka命令大全
    整理kafka相关的常用命令。 管理``` 创建topic(4个分区,2个副本)bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test kaf...
     半兽人 发布于5年前
    53
    推荐
    95k
    浏览
    kafka生产者Java客户端
    支持的版本- `>= 0.9` kafka客户端发布`record(消息)`到kafka集群。新的生产者是线程安全的,在线程之间共享**单个生产者**实例,通常单例比多个实例要快。一个简单的例子,使用producer发送一个有序的key/value(键值对),放到java的`main`方法里就能直...
     無名 发布于5年前
    40
    推荐
    91k
    浏览
    kafka接口API
    Apache Kafka引入一个新的java客户端(在org.apache.kafka.clients 包中),替代老的Scala客户端,但是为了兼容,将会共存一段时间。为了减少依赖,这些客户端都有一个独立的jar,而旧的Scala客户端继续与服务端保留在同个包下。 Kafka有5个核心API:1....
     半兽人 发布于5年前
    28
    推荐
    80k
    浏览
    kafka生产者API
    我们鼓励所有新开发的程序使用新的`Java生产者`,新的java生产者客户端比以前的Scala的客户端更快、功能更全面。通过下面的例子,引入Maven(可以更改新的版本号)。```org.apache.kafkakafka-clients3.0.0```如何使用生产者,请点击[这里](/303)。对...
     半兽人 发布于5年前
    92
    推荐
    80k
    浏览
    kafka消费者Java客户端
    一个从kafka集群中获取消息的java客户端。kafka客户端从kafka集群中获取消息,并透明地处理kafka集群中出现故障broker,透明地调节适应集群中变化的数据分区。也和broker交互,负载平衡消费者。 public class KafkaConsumer extends ...
     半兽人 发布于5年前
    321
    推荐
    70k
    浏览
    Kafka Broker配置
    3.1 Broker配置基本配置如下:* broker.id* log.dirs* zookeeper.connect下文将详细论述了主题级别配置和默认值。 kafka >= 0.10版名称|描述|类型|默认|有效值|重要程度---|---|---|---|---|---|zookeeper.co...
     半兽人 发布于5年前
1 / 56 跳转到