http://kafka.apache.org/0101/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html
Continue reading在同一个项目中使用同一工具的不同版本会产生冲突,可以通过改变包名来解决冲突,因为包的本来用途就是解决同名问题. 下面是shade kafka的pom文件: <?xml version="1.0" encoding="UTF-8"?> <project xm...
Continue reading设置从指定offset开始读取 在Flink 1.3.0及以上可以使用setStartFromSpecificOffsets设置从指定offset开始读取 Fault Tolerance 开启checkpoint即可 offset提交行为 如果checkpoint被禁用,F...
Continue reading1. 如何查看Linux系统当前状态 cpu, io, memory, network 进程列表，查找特定进程pid，进程的cpu, io, memory使用情况， 系统的打开文件句柄数，线程数，当前用户的打开文件句柄数，线程数 java进程 进程pid，内存使用情况，JV...
Continue reading使Flink输出的数据在多个partition中均匀分布 FlinkKafkaProducerBase的子类可以使用默认的KafkaPartitioner FixedPartitioner(只向partition 0中写数据)也可以使用自己定义的Partitioner(继承...
Continue reading接口改善 接口中可以定义默认方法和静态方法 interface A{ public default void Sf(){ System.out.println("A.Sf()"); } public static int name(...
Continue reading