使用Producer，ConsumerConnector HelloWorldProducer.java package cn.ljh.kafka.kafka_helloworld; import java.util.Date; import java.util.Properties; import... ...
分类：
编程语言 时间：
2017-06-04 09:48:39
阅读次数：
311
使用0.9开始增加的KafkaProducer和KafkaConsumer。 Pom.xml 4.0.0 cn.ljh.kafka kafka-helloworld 0.0.1-SNAPSHOT jar kafka-helloworld http://maven.apache.org UTF-8 j... ...
分类：
编程语言 时间：
2017-06-04 00:50:29
阅读次数：
399
往kafka集群发送消息时，报错如下： page_visits-1: 30005 ms has passed since batch creation plus linger time 加入log4j.properties，设置为DEBUG级别，错误如下： 2017-06-03 17:33:31,4... ...
分类：
编程语言 时间：
2017-06-03 19:14:00
阅读次数：
912
转载请在页首明显处注明作者与出处 一：说明 此为大数据系列的一些博文，有空的话会陆续更新，包含大数据的一些内容，如hadoop,spark,storm,机器学习等。 当前使用的hadoop版本为2.6.4 上一篇:hadoop系列二：HDFS文件系统的命令及JAVA客户端API 二：wordcoun ...
分类：
其他好文 时间：
2017-06-03 12:51:54
阅读次数：
144
Kafka是一个分布式的、可分区的、可复制的消息系统。它提供了普通消息系统的功能，但具有自己独特的设计。这个独特的设计是什么样的呢？ 首先让我们看几个基本的消息系统术语： Kafka将消息以topic为单位进行归纳。 将向Kafka topic发布消息的程序成为producers. 将预订t... ...
分类：
其他好文 时间：
2017-05-23 15:48:41
阅读次数：
106
原文链接：http://blog.csdn.net/xyang81/article/details/52847311 Java客户端源代码和jar：链接：http://pan.baidu.com/s/1jHIwtsq 密码：n757 我将官方提供的sdk封装了一个工具类，将工具类导入工程即可使用，如 ...
分类：
编程语言 时间：
2017-05-21 12:55:01
阅读次数：
235
此贴仅作为本人redis入门学习的笔记记录。 redis是什么呢？简单直接点说，就是一个Key-Value类型的数据库。关于它的优缺点，本人暂时没有深入学习和了解，不敢妄言。 jedis：redis官方首选的Java客户端开发包。 因为redis是安装在Linux环境下的，所以在使用之前，我们需要做 ...
分类：
编程语言 时间：
2017-05-19 11:08:51
阅读次数：
130
添加maven依赖包 建立包结构 建立包结构如下图所示为例： 在log4j.properties中输入： 生产者代码 1 package com.juyun.kafka; 2 3 import java.util.Properties; 4 5 import org.apache.log4j.Pro ...
分类：
编程语言 时间：
2017-05-13 19:00:25
阅读次数：
487
迭代对于JAVA的来说绝对不陌生。我们常常使用JDK提供的迭代接口进行Java集合的迭代。Iteratoriterator=list.iterator();
while(iterator.hasNext()){
Stringstring=iterator.next();
//dosomething
}迭代其实我们可以简单地理解为遍历，是一个标准化遍历各类容器里面的所有对象..
分类：
其他好文 时间：
2017-05-11 22:15:54
阅读次数：
153
java客户端 1 package client; 2 3 import java.io.DataOutputStream; 4 import java.io.File; 5 import java.io.FileInputStream; 6 import java.io.IOException; ...
分类：
编程语言 时间：
2017-05-09 00:59:54
阅读次数：
216
