/** gz文件是linux下常见的压缩格式。使用 java.util.zip.GZIPInputStream即可，压缩是 java.util.zip.GZIPOutputStream*/压缩为.gz文件java代码如下，经本地测试未发现问题。public static void compressFile(String inFileName) {...

导入maven依赖，我测试用到的版本为3.2.0<dependency><groupId>cn.afterturn</groupId><artifactId>easypoi-base</artifactId><version>3.2.0</version></dependency>...

生产者拦截器生产者拦截器既可以用来在消息发送前做一些准备工作，比如按照某个规则过滤不符合要求的消息，修改消息的内容等，也可以用来在发送回调逻辑前做一些定制化的需求，比如统计类工作。生产者拦截器的使用也很方便，主要是自定义实现 org.apache.kafka.clients.producer.ProducerInterceptor接口。ProducerInterceptor接口中包含3个方法：Ka

一个典型的 Kafka 体系架构包括若干 Producer、若干 Broker、若干 Consumer，以及一个ZooKeeper集群，如下图所示。其中ZooKeeper是Kafka用来负责集群元数据的管理、控制器的选举等操作的。Producer将消息发送到Broker，Broker负责将收到的消息存储到磁盘中，而Consumer负责从Broker订阅并消费消息。（1）Producer：生产者，也

本人接触kafka也有一段时间，记录一下常用的一些命令，便于工作中使用，只是简单整理了几个常用命令，欢迎大家继续补充1 启动kafka服务./bin/kafka-server-start.sh config/server.properties &2 手动创建topicsh kafka-topics.sh --create --zookeeper localhost:2181 --repli

当一个新的消费组建立的时候，它根本没有可以查找的消费位移，或者消费组的内一个新消费者订阅了一个新的主题，它也没有可以查找的消费位移，当_consumer_offsets主题内有关这个消费组的位移信息过期而被删除以后，它也没有可以查找的消费位移。在Kafka中，每当消费者查找不到所记录的消费位移时，就会根据消费者客户端参数auto.offset.reset的配置来决定从何处开始进行消费，这个参数的默

以上是Java类文件的基本结构，每个部分都有其特定的格式和含义。Java类文件的结构是按照规范定义的，Java虚拟机可以根据类文件的结构加载、解析和执行类的相关操作。Java类文件是Java源代码经过编译后生成的二进制文件，它包含了Java类的结构和信息。

AES加密模式有ECB,CBC,CTR等AES填充模式有pkcs5padding， pkcs7padding， no padding等AES数据块则有128位 192位 256位AES加密密码，如果选择数据块128位，则要求密码长度为16,数据块192位则要求密码长度为24，数据块长度为256位，则要求密码长度为32AES的偏移量和AES加密类似AES输出则有base64和hex两种AES字符集有

新版的消费者客户端对此进行了重新设计，将全部消费组分成多个子集，每个消费组的子集在服务端对应一个GroupCoordinator对其进行管理，GroupCoordinator是Kafka服务端中用于管理消费组的组件。而消费者客户端中的ConsumerCoordinator组件负责与GroupCoordinator进行交互。ConsumerCoordinator与GroupCoordinator之间

1 在项目中，产品已经上线一段时间，出现新的需求，需要解决查询的时候，忽略大小写的问题。本人用于测试的索引结构如下PUT test_v1.000{"settings": {"number_of_replicas": 1,"number_of_shards": 5},"mappings": {"product": {"properties": {"name":{"type": "keywor...