当前位置: 首页 > 知识库问答 >
问题:

在模式注册表中,使用者的模式可能与生产者的模式不同,这实际上意味着什么

苍兴怀
2023-03-14

共有1个答案

赵刚豪
2023-03-14

Kafka使用者根据模式ID从模式注册表中获取模式

只有当您让反序列化器这样做时。

您可以在消费者代码中定义自己的、兼容的模式。因此,它可以是不同的,并遵循Avro模式演化的规则

 类似资料:
  • 一、线程间通信的两种方式 1.wait()/notify() Object类中相关的方法有notify方法和wait方法。因为wait和notify方法定义在Object类中,因此会被所有的类所继承。这些方法都是final的,即它们都是不能被重写的,不能通过子类覆写去改变它们的行为。 ①wait()方法: 让当前线程进入等待,并释放锁。 ②wait(long)方法: 让当前线程进入等待,并释放锁,

  • 我现在一直在查看Spring Cloud模式注册表和汇合模式注册表。我可以看到一些区别,例如Spring Cloud模式注册表将模式保存在普通数据库中,默认情况下保存在h2中,而汇合模式注册表保存在kafka主题中。 spring云模式注册表的这种方法是否会对性能产生任何影响。据我所知,即使数据保留在主题上,以防汇合,查询它时仍然会有延迟。但会有重大影响吗? 我还可以看到,spring云模式注册表

  • 我正在研究Kafka支持的事务生产者和这两个链接中描述的精确一次处理: 1)https://www.confluent.io/blog/exactly-once-semantics-are-possible-heres-how-apache-kafka-does-it/2)https://www.confluent.io/blog/transactions-apache-kafka/ 对于用户可以

  • 本文向大家介绍详解Python 模拟实现生产者消费者模式的实例,包括了详解Python 模拟实现生产者消费者模式的实例的使用技巧和注意事项,需要的朋友参考一下 详解Python 模拟实现生产者消费者模式的实例 散仙使用python3.4模拟实现的一个生产者与消费者的例子,用到的知识有线程,队列,循环等,源码如下: Python代码 在本例里面散仙启动了1个生产者线程,2个消费者线程,打印效果如下:

  • 我想知道用模板observer配置的observer模式是否比常规observer模式更方便。模板观察者的概念是一个可观察的类,它具有配置为模板的特定观察者类型。作为一个例子,我将展示一个普通的观察者,并将其与模板观察者进行比较。 正常观察者模式 正常观察者界面: 对于实现NormalObserver接口的每个类,更新函数都是相同的。如果要实现特定的观察者,例如具有不同更新参数的观察者,这会导致问

  • 我有一个生产者/消费者模式,如下所示 固定数量的生成器线程,每个线程写入它们自己的BlockingQueue,通过执行器调用 单个使用者线程,读取生产者线程 每个生产者都在运行一个数据库查询,并将结果写入其队列。消费者轮询所有生产者队列。目前,如果出现数据库错误,生产者线程就会死掉,然后消费者就会永远停留在产品队列中等待更多的结果。 我应该如何构造它来正确处理catch错误?