在轮询Kafka时,我使用该subscribe()功能订阅了多个主题.现在,我想设置的偏离,我想从每个主题阅读,而无需每次重新订阅后seek(),并poll()从一个话题.在轮询数据之前seek(),是否会迭代地调用每个主题名称来实现结果?如何在Kafka中准确存储偏移量?
我每个主题都有一个分区,只有一个消费者可以阅读所有主题.
我在我身上调用了两个函数char* s = "pratik":
用户代码:
#include <zlib.h>
int main()
{
char *s = "pratik";
printf("%x\n",crc32(0x80000000, s, strlen(s)));
return 0;
}
Run Code Online (Sandbox Code Playgroud)
输出:66fa3c99
内核代码:
#include <linux/crc32.h>
int main()
{
char *s = "pratik";
u32 checksum = crc32(0x80000000, s, strlen(s));
printk("\nChecksum --> %x", checksum);
return checksum;
}
Run Code Online (Sandbox Code Playgroud)
输出:
校验和 - > d7389d3a
为什么相同字符串的校验和值不同?
当他们说read(2)或open(1)时,有什么意思?括号中的数字实际上是什么意思?
编辑:改述问题的标题.