public class ReadFile2Kafka { public static void main(String[] args) throws Exception { if (args.length != 4) { throw new RuntimeException("参数列表: boot... ...
分类：
其他好文 时间：
2019-06-15 15:53:29
阅读次数：
78
Topic交换器，即主题模式，进行规则匹配。 一、Provider 配置文件 代码 二、Condumer 配置文件 infoReceiver logsReceiver ...
分类：
其他好文 时间：
2019-06-15 12:05:34
阅读次数：
71
1.安装并配置zk 2.安装并配置Kafka 3.启动zk 4.启动Kafka 5.创建topic 程序代码 记一次遇到的问题 https://www.cnblogs.com/feifeicui/p/11018761.html ...
分类：
Web程序 时间：
2019-06-13 20:49:09
阅读次数：
145
Controller机制 1 前言 Controller 是从Kafka集群中选取一个的broker，负责管理topic分区和副本的状态的变化，以及执行重分配分区之类的管理任务。 第一个启动的broker会成为一个controller，它会在Zookeeper上创建一个临时节点(ephemeral) ...
分类：
其他好文 时间：
2019-06-09 18:22:57
阅读次数：
106
副本和分区状态机 1 前言 Controller 是从Kafka集群中选取一个的broker，负责管理topic分区和副本的状态的变化，通过上篇我们知道了controller的启动流程，这篇我们学习一下分区和副本状态机。 分区状态机记录着当前集群所有 Partition 的状态信息以及如何对 Par ...
分类：
其他好文 时间：
2019-06-09 18:09:35
阅读次数：
84
一、问题答案 是不可以的 而且后注册的会替换前注册的，MqConsumer2会替换MqConsumer，并且只结束tag-2的消息 二、为什么呢？ 我们从源码的角度来分析下 1.订阅消息的方法 public void subscribe(String topic, String subExpress ...
分类：
其他好文 时间：
2019-06-08 01:07:33
阅读次数：
2837
I sometimes put what I hate most in my code, because I have to interact with somebody in my code, I have friends, I have enemies, I have what I hate v ...
分类：
其他好文 时间：
2019-06-07 19:09:41
阅读次数：
113
1、简介 Kafka is a distributed,partitioned,replicated commit logservice。它提供了类似于JMS的特性，但是在设计实现上完全不同，此外它并不是JMS规范的实现。kafka对消息保存时根据Topic进行归类，发送消息者成为Producer, ...
分类：
其他好文 时间：
2019-06-06 19:30:48
阅读次数：
134
Django之Form组件 Django的Form主要具有一下几大功能： 生成HTML标签 验证用户数据（显示错误信息） HTML Form提交保留上次提交数据 初始化页面显示内容 小试牛刀 1、创建Form类 from django.forms import Form from django.fo ...
分类：
其他好文 时间：
2019-06-05 16:34:04
阅读次数：
88
接到的项目是：spring的项目做spring整合rabbitMQ的作生产者，而测试使用springboot整合RmQ做消费者，交换机模式 Topic,这里还涉及到队列和消息的持久化,这里稍作总结！ spring整合rabbitMQ的作生产者： pom.xml: rabbitMq.xml aappl ...
分类：
其他好文 时间：
2019-06-05 16:29:37
阅读次数：
102
