Kafka 源码解析之 Topic 的新建/扩容/删除（二十）
06月18日
本篇接着讲述 Controller 的功能方面的内容，在 Kafka 中，一个 Topic 的新建、扩容或者删除都是由 Controller 来操作的，本篇文章也是主要聚焦在 ...标签：Apache Kafka
GSoC Project Intro: Jenkins Remoting over Message Bus/Queue
06月18日
About me My name is Pham Vu Tuan, I am a final year undergraduate student from Singapor...
GSoC Project Intro: Jenkins Remoting over Message Bus/Queue
06月18日
About me My name is Pham Vu Tuan, I am a final year undergraduate student from Singapor...Interesting Stuff – Week 24
06月18日
Throughout the week, I read a lot of blog-posts, articles, and so forth, that has to do w...
Siphon: Streaming data ingestion with Apache Kafka
06月18日
Data is at the heart of Microsoft’s cloud services, such as Bing, Office, Skype, and many...spark streaming kafka 整合
06月17日
package com.immooc.spark import org.apache.kafka.clients.consumer.ConsumerRecord import...
Analysing Network Data with Apache Kafka, KSQL, and Elasticsearch
06月17日
In this article I demonstrated how to use KSQL to enrich streams of network event data. ...
Analysing Network Data with Apache Kafka, KSQL, and Elasticsearch
06月17日
In this article I demonstrated how to use KSQL to enrich streams of network event data. ...
Kafka 源码解析之 Broker 上线下线（十九）
06月17日
本篇接着讲述 Controller 对于监听器的处理内容 —— Broker 节点上下线的处理流程。每台 Broker 在上线时，都会与 ZK 建立一个建立一个 session...kafka 简单 java 生产消费API
06月17日
1. KafkaProperties package com.immooc.spark.kafka;public class KafkaPropertie...kafka 简单 java 生产消费API
06月17日
1. KafkaProperties package com.immooc.spark.kafka;public class KafkaPropertie...
flume 收集日志到 kafka 整合
06月17日
就是服务器B的Sink要换成kafka 的sink即可 服务器A还是不变： # Define a memory channel called ch1 on agent1 ...实战Kafka ACL机制
06月17日
1.概述 在Kafka0.9版本之前，Kafka集群时没有安全机制的。Kafka Client应用可以通过连接Zookeeper地址，例如zk1:2181:zk2:2181,zk...
Kafka 源码解析之 Partition 副本迁移实现（十八）
06月16日
前面两篇关于 Controller 的内容分别讲述了 Controller 选举和启动，以及副本状态机和分区状态机的内容，从本文开始会详细讲述 Controller 的一些其他功...kafka 单机环境搭建
06月16日
1. 安装zookeeper kafka要先安装zookepper1.1下载解压zookeeper1.2 conf/zoo_samp...
Kafka 源码解析之副本状态机与分区状态机（十七）
06月16日
上篇讲述了 KafkaController 的启动流程，但是关于分区状态机和副本状态机的初始化并没有触及，分区状态机和副本状态机的内容将在本篇文章深入讲述。分区状态机记录着当前集...
KBrowse: Kafka Search
06月16日
KBrowse: Kafka Search Photo credit: fanjianhuaPandora i...Democratizing Stream Processing with Apache Kafka and KSQL
06月15日
Key TakeawaysMost stream processing technologies require you to write code in programm...
Kafka 源码解析之 Controller 选举及服务启动流程（十六）
06月15日
从本篇文章开始，Kafka 源码解析就正式进入了 Controller 部分，Controller 作为 Kafka Server 端一个重要的组件，它的角色类似于其他分布式系统...Kafka常用命令
06月15日
启动命令 启动kafka很简单，配置好前置的操作后，先进入zookeeper的目录下，启动zookeeper cd zookeeper-3.4.6 # 启动zoo...使用docker安装kafka
06月15日
我们这里使用第三方docker镜像来安装kafka环境，分别是： wurstmeister/kafka 和 wurstmeister/zookeeper ，如需修...Maxwell, De MariaDB a Kafka
06月15日
Y si os dijera que podeis enviar todas las transacciones de MariaDB a Kafka sin tener que...Fronting Cluster: A reliable solution for publishing data to Kafka
06月14日
Fronting Cluster: A reliable solution for publishing data to Kafka We see 6 Billion+ eve...
Kafka入门学习
06月14日
Kafka学习 注：本文所有资料均可从 https://github.com/leichenjie/kafka 下载 1. 简介 Kafka是一个分布式的消息队列，也是一个...
量化交易系统任务框架的演化之路（5）用Kafka实现分布式计算任务框架
06月14日
在之前的几篇文章中，都是基于单服务器系统讲解了任务框架的逐步演化，包含了效率、依赖关系、可管理性等几个方面的内容。可是随着量化系统的中因子、信号、数据预处理、日志监控等需求的不断...Akka, Spark, or Kafka? Selecting the Right Streaming Engine [Video]
06月14日
Many engineers we talk to on a daily basis come to us with the same issue: that the batch...Akka, Spark, or Kafka? Selecting the Right Streaming Engine [Video]
06月14日
Many engineers we talk to on a daily basis come to us with the same issue: that the batch...Last Week in Stream Processing & Analytics – 13.6.2018
06月14日
This is the 118th edition of my blog series blog series around Stream Processing and Anal...Bistro Streams – new approach to stream analytics (like Kafka Streams)
06月14日
____ _ _ | __ )(_)___| |_ _ __ ___ ___________________________ | _ | / __| __| '...
kafka和websocket实时数据推送
06月13日
已有Kafka服务，通过kafka服务数据（GPS）落地到本地磁盘（以文本文件存储）。现要根据echarts实现一个实时车辆的地图。 分析前端实时展现：使用websock...