最近项目上因为遇到数据量过大导致查询统计性能问题（oracle数据库、单表每月1亿多条车辆定位记录，由一个windows环境下的链路服务程序来接收车辆上传的定位数据写入oracle），急需使用大数据架构来解决。前期同事已经提出整体解决思路（修改链路服务程序，在写oracle的基础上同时写入 ...

首先说明一点，像Confluent.Kafka这种开源的组件，三天两头的更新。在搜索引擎搜索到的结果往往用不了，浪费时间。建议以后遇到类似的情况直接看官网给的Demo。 因为搜索引擎搜到的文章，作者基本上都没有说明用的是哪个版本的dll。所以你nuget安装了后，不一定能使用。 截止目前 ...

一、引言 　　研究Kafka有一段时间了，略有心得，基于此自己就写了一个Kafka的消费者的类和Kafka消息生产者的类，进行了单元测试和生产环境的测试，还是挺可靠的。 二、源码 　　话不多说，直接上代码，代码不是很难，注释很全，希望大家多多发表意见，继续提升。 　　以上类型 ...

上个章节我们讲了kafka的环境安装（这里），现在主要来了解下Kafka使用，基于.net实现kafka的消息队列应用，本文用的是Confluent.Kafka，版本0.11.6 1、安装： 在NuGet程序包中搜索“Confluent.Kafka”下载安装即可 2、producer ...

，今天主要是上干货，主要是代码，今天就把Kafka的消费者和生产者的代码贴出来，以供大家参考，当然这个是 ...

一：kafka介绍 kafka（官网地址：http://kafka.apache.org）是一种高吞吐量的分布式发布订阅的消息队列系统，具有高性能和高吞吐率。 1.1 术语介绍 Broker Kafka集群包含一个或多个服务器，这种服务器被称为broker Topic ...

一、生产者 librdkafka进行kafka生产操作的大致步骤如下： 1、创建kafka配置 2、配置kafka各项参数 3、设置发送回调函数 4、创建producer实例 5、创建topic 6、异步调用将消息 ...

Kafka学习资料 http://blog.csdn.net/bluetom520/article/details/54892959 https://www.infoworld.com/article/3215165/application-development ...