消费者如何在从Kafka broker获取数据之前检查模式注册表是否可访问？
据我所知，Kafka使用者将在第一次从代理反序列化avro数据时，前往模式注册中心获取和缓存数据模式，以备将来使用。
在所有这些开始之前，消费者进程是否有可能首先检查架构注册表是否可达（如网络问题或注册表意外关闭或其他什么）？
共有1个答案
您可以在使用者循环之外使用CachedSchemaRegistryClient或HttpURLConnection类来进行HTTP连接。
-
我将 Kafka 提交策略设置为最新且缺少前几条消息。如果我在开始将消息发送到输入主题之前先睡20秒，那么一切都按预期工作。我不确定问题是否与消费者需要很长时间进行分区重新平衡有关。有没有办法在开始轮询之前知道消费者是否准备好了？
-
我目前正在做一个kafka java项目。我是新来的，我发现很难理解与Kafka生产者/消费者设计相关的几个基本概念。 > 比方说，我有一个带有单个分区的主题，我有一个生产者正在写这个主题，一个消费者正在从这个主题中消费。如果我部署同一个应用程序的多个实例，每个实例将运行自己的消费者。在这种情况下，因为所有消费者都属于同一个group pId，所以消息是否会在多个实例上运行的消费者之间平均分配？
-
本文向大家介绍Kafka 的消费者如何消费数据相关面试题，主要包含被问及Kafka 的消费者如何消费数据时的应答技巧和注意事项，需要的朋友参考一下 消费者每次消费数据的时候，消费者都会记录消费的物理偏移量（offset）的位置 等到下次消费时，他会接着上次位置继续消费
-
首先定义注册表主键： !define HKEY_CLASSES_ROOT 0x80000000 !define HKEY_CURRENT_USER 0x80000001 !define HKEY_LOCAL_MACHINE 0x80000002 !define HKEY_USERS 0x80000003 利用RegOpenKey这个API的返回值进行判断： 如果$R1=0，则该注册表键存在； $R
-
如果不是--如何修复？
-
本文向大家介绍Kafka 消费者是否可以消费指定分区消息？相关面试题，主要包含被问及Kafka 消费者是否可以消费指定分区消息？时的应答技巧和注意事项，需要的朋友参考一下 Kafa consumer消费消息时，向broker发出fetch请求去消费特定分区的消息，consumer指定消息在日志中的偏移量（offset），就可以消费从这个位置开始的消息，customer拥有了offset的控制权，可