解释kafka偏移的作用。
答：给分区中的消息提供了一个顺序ID号，我们称之为偏移量。因此，为了唯一地识别分区中的每条消息，我们使用这些偏移量。
-
我目前正在从具有特定偏移量的主题中获取消息。我正在使用寻求（）来实现它。但是当我将enable.auto.commit设置为true或使用手动同步（委托同步（）/委托同步（））时，Seek（）不起作用，因为它没有轮询来自特定偏移量的消息，而是从最后提交的偏移量中选择。 因此，在使用Seek（）时，是否必须将偏移量存储在外部DB中，而不提交给Kafka？Seek和Commit不能并行工作吗？ 客户端
-
本文向大家介绍解释Kafka Producer API的作用。相关面试题，主要包含被问及解释Kafka Producer API的作用。时的应答技巧和注意事项，需要的朋友参考一下 答：允许应用程序将记录流发布到一个或多个Kafka主题的API就是我们所说的Producer API。
-
我有一个问题，假设有一个TOPIC T1，有两个消费者C1和C2属于两个不同的组，电流偏移量是0.我们知道Kafka维护消费者的偏移量。因此，如果 C1 使用消息并且 Offset 变为 1，那么如果 C2 使用消息，它将从 1 偏移量开始，还是从 0 偏移量开始使用消息，会发生什么情况？表示两个不同的消费群体将如何维持抵消？ 谢啦
-
我有一个ReactorKafka项目，它消耗来自Kafka主题的消息，转换消息，然后写入到另一个主题。 我的理解是，只有在Reactor中成功完成所有顺序步骤后，才会提交偏移量。对吗？我想确保不会处理下一条记录，除非当前记录成功发送到目标Kafka主题。
-
我用Kafka和spring-布特： Kafka制作人班： Kafka-配置： 问题： 我有一个主题的5个分区，比方说。 发生的情况是，我获得成功（即消息成功发送到Kafka）日志，但是topic的无分区的偏移量增加。 正如您在上面看到的，我添加了日志和。我所期望的是，当Kafka不能发送消息给Kafka时，我应该得到一个错误，但在这种情况下，我没有收到任何错误消息。 Kafka的上述行为以的比例
-
我过去曾与Kafka合作过一点，最近需要将部分数据管道移植到AWS Kinesis Stream上。现在我读到Kinesis实际上是Kafka的一个分支，并且有许多相似之处。 然而，我没有看到如何让多个消费者从同一个流中读取数据，每个消费者都有相应的偏移量。每个数据记录都有一个序列号，但我找不到特定于消费者的任何内容（Kafka组Id？）。 在同一个AWS Kinesis Stream上，真的有可