发布时间：2018-06-30 20:32:00
分区模式将记录进行分类，但它并不关心记录的顺序。其主要目的是将数据集中相似的记录分成不同的、更小的数据集 分区主要原理是，自定义分区类继承Partitioner，根据业务需求实现分区函数 public int getPartition(Text key, Text value, int numPartitions)，将Key相同的记.........【阅读全文】
发布时间：2023-08-04 19:00:24
内核态程序点击(此处)折叠或打开#include <linux/init.h>#include <linux/module.h>#include <linux/types.h>#include <net/sock.h>#include <linux/netlink.h>#include <linux/kthread.h>.........【阅读全文】
发布时间：2023-08-04 18:56:44
用户态程序点击(此处)折叠或打开#include <stdio.h>#include <stdlib.h>#include <sys/socket.h>#include <string.h>#include <linux/netlink.h>#include <stdint.h>#inc.........【阅读全文】
发布时间：2023-08-04 18:53:11
1、用户态API1、创建socketInt skfd = socket(PF_NETLINK, SOCK_RAW, NL_IMP2)l 第一个参数必须是 AF_NETLINK 或 PF_NETLINK，在 Linux 中，它们俩实际为一个东西，它表示要使用netlink，l 第二个参数必须是SOCK_RAW或SOCK_DGRAM， 因为netlink是一个面向数据报的服.........【阅读全文】
发布时间：2021-02-26 10:46:43
最近有个项目需求，有个数据转发服务，需要从kafka消息队列消费数据，然后转发到rabbitmq。要求转发数据不重复，且不能丢失数据。这里主要考虑转发的目的地址网络异常时，数据不能送达情况，当网络恢复时，要接着异常前发送的记录继续发送。 要来实现此功能，需要先清楚kafka消费原理： kakfa用offs.........【阅读全文】
