我使用的是confluent Schema Registry，我在同一主题下注册了多个模式。如果我试图发布一条记录，架构Id是作为记录的一部分发送的(即使来自缓存)，还是仅仅在将新版本的架构注册到架构注册表时发送？
浏览 20提问于2019-12-25得票数 1
回答已采纳
1回答
如果我们在Kafka中使用模式注册表，是否每个生产者都需要在每次将记录发送到代理时发送当前版本的Kafka？
如果是，那么额外的开销有什么意义，因为我们已经在每个avro文件中发送模式了？如果不是，请为我的问题的愚蠢感到遗憾，并请帮助我更好地理解模式注册表。
浏览 0提问于2017-10-31得票数 0
有两种选择：
日志记录应用程序具有它的本地RabbitMQ实例，每个日志发布应用程序都在该实例上传递其消息选项1要求我在每次新应用程序出现或移动时重新配置/重新编码/通知记录应用程序。因此，我认为选项2是正确的，每个<em
浏览 0提问于2015-07-28得票数 0
在我的应用程序中，我使用Spring作为发现服务器，它是使用微服务架构实现的。这些服务大多是用PHP创建的，它们在启动时使用Eureka REST端点注册，每个端点每30秒发送一次心跳，一切正常工作。
现在，想象一下服务A想和服务B对话，这个发现是怎么发生的？目前，我认为服务A应该向http://localhost:8761/eureka/apps/service-B端点发送<
浏览 5提问于2017-11-10得票数 1
我是卡夫卡和阿夫罗的菜鸟。所以我一直在努力让生产者/消费者运行。到目前为止，我已经能够使用以下方法生成和使用简单的Bytes和String:生产者的配置： props.put(硬编码模式，然后尝试创建一个泛型记录以通过KafkaProducer发送生产者现在设置为：pro
浏览 8提问于2017-08-11得票数 27
回答已采纳
1回答
嘿，我想在Avro序列化器中使用汇合模式注册表:文档现在基本上是这样的:不要对多个不同的使用相同的模式因此，我没有看到多次使用模式期望冗余的问题吗？
浏览 4提问于2016-07-21得票数 2
5回答
我可以注册我的设备，并且我会得到一个注册Id。令我惊讶的一件事是，如果我试图在几秒钟内注册一个设备两次，我会得到一个不同的注册id。最有可能的是他们把时间当做种子。
这个注册
浏览 2提问于2011-12-22得票数 0
回答已采纳
为此，我希望创建自己的媒体类型(application/vnd[...]+xml和application/vnd[...]+json)。媒体类型将定义我的消息格式，因此我需要添加XML模式和JSON模式，以配合新的媒体类型(这样REST客户端就可以知道消息中的内容和发送回什么)。我已经在网上做了一些研究，但是一个人
浏览 6提问于2013-02-04得票数 36
回答已采纳
2回答
产品服务减少其DB中的一个单元的产品库存，并在“订单”中发布一条消息，上面写着PRODUCT_RESERVED。订单服务获取PRODUCT_RESERVED消息，并命令支付，发布消息PAYMENT_REQUESTED
产品服务增加数据库中的库存以取消预订并发布PRO
浏览 6提问于2017-02-13得票数 2
by: org.apache.kafka.common.errors.SerializationException: Error retrieving Avro unknown schema for idSchema 16 not foundio.confluent.rest.exceptions.RestNotFoundException: Schema 16 not found我想知道为什么应用程序试图找到模式16
浏览 5提问于2022-07-25得票数 0
1回答
总之:服务器1(合流安装)服务器2(请求消费者和回复生产者应用程序)服务器3(请求发送者和回复消费者应用程序)
分区测试<
浏览 1提问于2018-09-07得票数 2
回答已采纳
我想了解一下卡夫卡的交易，特别是我是如何使用transaction.id的。以下是背景：
有一个具有工作线程的线程池，用于对输出主题进行消息处理和发布。目前，每个线程都有自己
浏览 1提问于2018-05-14得票数 26
我需要在我的处理程序中获取msmq消息的Id，这样我就可以将该Id写入日志。
当一条消息被发送到错误队列时，会发送一封电子邮件，通知我们一条失败的消息。一旦导致消息的错误得到解决，我们需要使用'ReturnToSourceQueue‘NServiceBus工具再次尝试该消息。如果不记录该Id，在查看<
浏览 4提问于2013-10-03得票数 3
回答已采纳
2回答
我需要设计一个集成5-6遗留CRM的CRM“平台”的架构。一个重要的功能是在一个仪表板中显示存储在其他CRM中的客户记录。实际记录被存储在他们自己的CRM中进行编辑。一个问题是:我是否应该存储一组关于这些记录的最低限度的信息？解决办法可以是：
调用每个CRM，组装BFF中的所有内容，并将结果服务于平台的CRM。另一种解决方案可以是将创建/
浏览 0提问于2021-11-06得票数 0
我有一个春季应用程序，这是我的卡夫卡制作人，我想知道为什么阿夫罗是最好的方式。我读到了它和它所能提供的一切，但是为什么我不能把我和杰克逊一起创造出来的POJO串行化，然后寄给卡夫卡呢？我这么说是因为阿夫罗的POJO一代并不那么直接。除此之外，它还需要一个maven插件和一个.avsc文件。例如，我的卡夫卡制作人有一个名为User的POJO：
pu
浏览 4提问于2019-01-15得票数 12
回答已采纳
我从卡夫卡的话题中吸取了德鲁伊的数据。现在我想把我的卡夫卡主题转移到新的卡夫卡集群。在不重复数据和不停机的情况下，有什么可能做到这一点？在两个卡夫卡集群中生成数据:在新
浏览 21提问于2022-05-10得票数 0
我有一个发布者，正在将消息推送到一个主题。我有多个订阅者，当他们使用来自主题的消息时，每个订阅者都做不同的任务。现在，我希望我的系统可以扩展到运行在不同主机/相同主机上的同一进程的多个实例。例如，我想在不同的主机上运行我的应用程序A的多个副本，以便如果A的一个实例运行缓慢，则其他实例可以拉入后续消息并取得进展。我发现使用虚拟目的地可以做
浏览 1提问于2012-01-03得票数 5
2回答
我实现了一个简单的卡夫卡死信记录处理器。
当使用从控制台生产者产生的记录时，它工作得很好。当记录被流应用程序不匹配处理时，它们会移动到死信主题，而不是继续往下流。发布新数据时，我们将死信主题中的最新消息转储回流应用程序的源主题，以便使用新数据进行重新处理。向使用者组协调器发送指定偏移量的列表，并将这些偏移量标记
浏览 0提问于2019-02-11得票数 5
回答已采纳
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
