我做的是 Streaming拉取kafka的直连方式 案例 错误原因是我包引入错误 你们好好检查一下 ...
分类：
Web程序 时间：
2019-08-18 09:30:16
阅读次数：
269
请使用0.9以后的版本： 示例代码 1、只需要配置kafka的server groupid autocommit 序列化 autooffsetreset(其中 bootstrap.server group.id key.deserializer value.deserializer 必须指定); 2 ...
分类：
编程语言 时间：
2019-08-16 10:25:45
阅读次数：
69
一、基于Receiver的方式1、概述基于Receiver的方式：Receiver是使用Kafka的高层次Consumer API来实现的。receiver从Kafka中获取的数据都是存储在Spark Executor的内存中的，然后Spark Streaming启动的job会去处理那些数据。然而，... ...
分类：
其他好文 时间：
2019-08-13 15:41:08
阅读次数：
99
概念 Kafka 是一个快速、可扩展和高可用的基于发布 订阅模式（pub sub model）的消息系统，用作消息中间件，在系统之间传递消息。其核心概念有： Topic（话题） Producer（生产者） Consumer（消费者） Broker（经纪人） 在 Kafka 中，所有的消息都由 Top ...
分类：
其他好文 时间：
2019-08-11 12:44:35
阅读次数：
108
fetch.min.bytes. #获取最小字节数据 Consumer 向broker中要数据时是按大小来返回的，如果数据没有达到指定的MB，consumer会处于等待状态，直到broker 从producer 哪里获取到指定大小的数据为止。获取取的最小数据大小是指的每个partition上的数据。... ...
分类：
其他好文 时间：
2019-08-06 00:41:49
阅读次数：
92
在dubbo中，如何区分dubbo的provider和consumer？ 在以前的认知中，通过学习，认为dubbo的provider端就是提供接口并且实现接口的一方。consumer是调用这个接口的一方。。 然而有一次让我深深的怀疑了自己。。。并且由于比较忙也没有仔细研究一番，这也让我怀疑自己了好几 ...
分类：
其他好文 时间：
2019-08-03 21:29:56
阅读次数：
168
今天我们还讲讲Consumer、Supplier、Predicate、Function这几个接口的用法，在Java8的用法当中，这几个接口虽然没有明目张胆的使用，但是，却是润物细无声的。为什么这么说呢？这几个接口都在java.util.function包下的，分别是Consumer（消费型）、supplier（供给型）、predicate（谓词型）、function（功能性），相信有了后面的解释，
分类：
编程语言 时间：
2019-08-02 16:37:23
阅读次数：
86
这里是两个lambda表达式 andThen ...
分类：
编程语言 时间：
2019-08-01 00:21:04
阅读次数：
160
一、Eureka基本架构 1、Eureka角色结构图 角色职责如下： 1）、Register：服务注册中心，它是一个Eureka Server ，提供服务注册和发现功能。 2）、Provider：服务提供者，它是一个Eureka Client ，提供服务。 3）、Consumer：服务消费者，它是一 ...
分类：
编程语言 时间：
2019-07-30 23:27:53
阅读次数：
127
