FlinkKafkaConsumer consumer = new FlinkKafkaConsumer("topic", new SimpleStringSchema(), props);/*** Flink从topic中最初的数据开始消费*/consumer.setStartFromEarliest();/*** Flink从topic中指定的时间点开始消费，指定时间点之前的数据忽略*/con

查看各个patition消息的最大Offsetbin/kafka-run-class.sh kafka.tools.GetOffsetShell --topic topic_name --time -1 --broker-list host1:9092,host2:9092,host3:9092查看各个partition消息的最小Offsetbin/kafka-run-class.sh kafka

下面先来个Producer生产者的Demo案例：import org.apache.kafka.clients.producer.Callback;import org.apache.kafka.clients.producer.KafkaProducer;import org.apache.kafka.clients.producer.ProducerRecord;import org.apac

下面先来个消费者Demo:import java.util.Arrays;import java.util.Properties;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import org.apache.kafka.clients.consumer.ConsumerReco

Kafka的生产者KafkaProducer是线程安全的，然而消费者KafkaConsumer却是非线程安全的。KafkaConsumer定义了一个acquire()方法，用来检测当前是否只有一个线程在操作，若有其它线程正在操作会抛出ConcurrentModifycationException异常：java.util.ConcurrentModifycationException: K...

1 HBase系统架构Client职责1、HBase有两张特殊表：.META.：记录用户所有表拆分出来的Region映射信息，.META可以有多个Region-ROOT-：记录了.META.表的Region信息，-ROOT-只有一个Region，无论如何都不会分裂split2、Client访问用户数据前需要首先访问Zookeeper，找到-ROOT-表的Region所在的服务器位置，然后访问-RO

页缓存是操作系统实现的一种主要的磁盘缓存，以此用来减少对磁盘I/O的操作。具体来说，就是把磁盘中的数据缓存到内存中，把对磁盘的访问变为对内存的访问。为了弥补性能上的差异 ，现代操作系统越来越多地将内存作为磁盘缓存，甚至会将所有可用的内存用途磁盘缓存，这样当内存回收时也几乎没有性能损失，所有对于磁盘的读写也将经由统一的缓存。当一个进程准备读取磁盘上的文件内容时，操作系统会先查看待读取的数据所在的页（