有人能解释一下Kafka文献中的“记录流”是什么意思吗？
https://kafka.apache.org/intro
producerapi允许应用程序将记录流发布到一个或多个kafka主题。
我最近开始在Kafka工作，我一直在向Kafka集群发布/制作记录，但这些记录是一个接一个地推送的。当我读到“记录流”的时候，我的头都绕不过去了。我知道kafka有助于使用kstream和ksql构建流应用程序，但producerapi如何帮助推送“记录流”？这是否意味着批量记录并立即推送？
有人能解释一下Kafka文献中的“记录流”是什么意思吗？
https://kafka.apache.org/intro
producerapi允许应用程序将记录流发布到一个或多个kafka主题。
我最近开始在Kafka工作，我一直在向Kafka集群发布/制作记录，但这些记录是一个接一个地推送的。当我读到“记录流”的时候，我的头都绕不过去了。我知道kafka有助于使用kstream和ksql构建流应用程序，但producerapi如何帮助推送“记录流”？这是否意味着批量记录并立即推送？
1条答案
按热度按时间6qftjkof1#
流可以被认为是一段时间内数据的一致模型。尽管可以为主题生成随机数据，但序列化程序和反序列化程序希望代理的两侧都有一致的类型
你的问题和问为什么没什么区别
InputStream以及OutputStream当它们“一个接一个”地发送字节时，就以这种方式命名