# 云消息队列 Kafka 版 #
0
关注
10035内容
Flink Kafka Connector 与 Exactly Once 剖析
Flink Kafka Connector 是 Flink 内置的 Kafka 连接器，它包含了从 Kafka Topic 读入数据的 Flink Kafka Consumer 以及向 Kafka Topic 写出数据的 Flink Kafka Producer，除此之外 Flink Kafa Connector 基于 Flink Checkpoint 机制提供了完善的容错能力。
|
Kafka分布式安装及验证测试
一、安装
Kafka依赖于ZooKeeper，所以在安装Kafka之前请确保ZooKeeper集群已安装正确并能正常运行。虽然Kafka自身内置了ZooKeeper，但是还是建议大家单独部署ZooKeeper集群，因为可能其他框架也需要使用ZooKeeper。
|
一脸懵逼学习KafKa集群的安装搭建--（一种高吞吐量的分布式发布订阅消息系统）
1：KafKa的官方网址：http://kafka.apache.org/
开发流程图，如：
2：KafKa的基础知识：
2.1：kafka是一个分布式的消息缓存系统2.2：kafka集群中的服务器都叫做broker2.
|
X-Pack Spark使用[FAQ]
概述
本文主要列出在使用X-Pack Spark的FAQ。
Spark Connectors
主要列举Spark 对接其它数据源遇到的问题
Spark on HBase
Spark on HBase Connector：如何在Spark侧设置HBase参数。
|
kafka_2.11-0.11.0.1集群搭建
本文搭建一个三节点的Kafka集群。该集群有三个Zookeeper、三个Kafka Broker。
一、准备工作
解压kafka安装包，获得如下目录：
unzip kafka_2.
|
Spark-Spark Streaming-广告点击的在线黑名单过滤
任务
广告点击的在线黑名单过滤
使用 nc -lk 9999
在数据发送端口输入若干数据，比如：
1375864674543 Tom
1375864674553 Spy
1375864674571 Andy
1375864688436 Cheater
...
|
Net使用RdKafka引发异常RdKafka.Internal.LibRdKafka 的类型初始值设定项引发异常
在Net中VS2015用RdKafka组件开发消息发布和消费，引发下面的异常
RdKafka.Internal.LibRdKafka 的类型初始值设定项引发异常System.TypeInitializationException: “RdKafka.Internal.LibRdKafka”的类型初始值设定项引发异常。
免费试用