依赖 <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> </dependency> 代码 package com.perfect.kafka; import org.apac ...
分类：
其他好文 时间：
2020-07-21 01:09:32
阅读次数：
114
//可以使用ConsumerReBalanceListener来扩展实现自定义存储 //提交方法和获取offset方法得自己实现 ...
分类：
其他好文 时间：
2020-07-21 01:00:04
阅读次数：
71
思考： 1，消息丢失是什么造成的，从生产端和消费端两个角度来考虑？ 2，消息重复是什么造成的，从生产端和消费端两个角度来考虑？ 3，如何保证消息有序？ 4，如果保证消息不重不漏，损失的是什么？ 1.为什么会发生消息丢失和消息重复？消息发送Kafka消息发送有两种方式：同步（sync）和异步（asyn ...
分类：
其他好文 时间：
2020-07-21 00:57:57
阅读次数：
177
<div id="cnblogs_post_body" class="blogpost-body "> <p><strong>Broker Configs</strong></p><p> </p><p> </p><table style="width: 800px; ...
分类：
其他好文 时间：
2020-07-20 17:18:44
阅读次数：
72
1、在van-tabs上绑定点击事件（getQuestionByTypeid2） <van-tab title="热榜"> <div id="hot-list-title"> <van-tabs v-model="typeid" sticky offset-top="43" @click="getQ ...
分类：
其他好文 时间：
2020-07-20 17:16:19
阅读次数：
251
1.创建一个topic （它有一个分区和副本） bin\windows\kafka-topics.bat --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 2.查看已有的top ...
1：jquery的对DOM节点的基本操作 1)获取和设置HTML $('#id').html(); //()中没有值时为获取，有值时为设置 2)获取和设置文本（text） $('.class').text(); //()中没有值时为获取，有值时为设置 3)获取和设置value值 $('input[n ...
分类：
Web程序 时间：
2020-07-19 11:22:07
阅读次数：
91
一、下载及安装配置 JDK (Kafka依赖于Zookeeper服务，而Zookeeper的运营依赖JDK) 1.地址：https://www.oracle.com/java/technologies/javase-jdk14-downloads.html 下载windows可执行文件，直接点击安装 ...
仅罗列了一些常用基础配置，更多配置请到官网查看 https://www.elastic.co/guide/en/logstash/current logstash.yml配置文件 # Node identity #节点名称，默认主机名 node.name: test # Data path #数据存 ...
分类：
其他好文 时间：
2020-07-18 22:04:24
阅读次数：
88
前提：需要提前下载JDK 1.下载地址：https://kafka.apache.org/ 2.需要先启动ZooKeeper服务器(可以通过与kafka打包在一起的便捷脚本来快速简单地创建一个单节点ZooKeeper实例。) 命令： bin\windows\zookeeper-server-star ...
