《kafka》专题

我正试图使用SpringKafka为我的生产者应用程序及其嵌入式Kafka服务器编写测试。 然而，我的应用程序也使用合流模式注册表，我想知道SpringKafka是否为模式注册表提供了一些嵌入式服务器？ 或者有没有更好的方法来使用模式注册表进行Spring Kafka测试？

因此，我实现了一个自定义SerDe，它从Confluent提供的扩展到每当与模式注册表通信超时时，都会尝试重试。我已将Spring Cloud Streams Kafka binders配置为默认使用： 今天我在日志中看到了这个错误： 这告诉我Kafka Streams使用的SerDe不是我上面定义的SerDe，而是基类SpecificAvroSerde（它包装SpecificAvroSerial

我有一个spring boot应用程序，其中我有一个Kafka消费者。 我还希望更清楚地了解什么是消息侦听器容器和最终的消息侦听器。 提前谢谢你。

我有一个使用Spring cloud stream和Kafka Streams活页夹的项目。对于流的输出，我使用的是Avro，Serde由Confluent提供（

我正在向kafka发送对应于Avro记录的字节数组。 生产商： 消费者： 生产者能够将字节数组发送到主题。但消费者无法将其反序列化。我有一个错误： 无法将B转换为com。瑞士报价。埃弗雷克斯。生成。阿夫罗。交易。客户端请求 当我生成消息时，客户端订单请求值主题已在模式注册表上注册。我知道我发送了一个字节数组，并且kafka/模式注册表期望一个Avro记录，但我希望它能够反序列化它。 如果不能使用简

我有两个不同的主题要阅读，并将处理后的数据发布到WebService。我有一个条件，我必须完全读取来自topic1的消息，并确保如果没有来自topic1的消息，我必须读取来自topic2的消息并处理它。如果我开始从topic2读取消息并从topic1获取消息，我必须暂停处理来自topic2的消息并从topic1读取消息。 我设法使用KafkalistenerEndpointRegistry实现了这

由于我有几个主题，结果代码非常冗长： 如何通过配置注释的属性，使这种重复配置更加简洁？

如何使用Spring Kafka通过合流模式注册表读取AVRO消息？有样品吗？我在官方参考文件中找不到它。

我正在寻找一个简单可行的示例，该示例使用Spring Cloud Stream Kafka和Confluent Schema Registry（producer

我使用spring-kafka注释@kafkalistener来指定我的侦听器方法。 我使用单个分区的单个主题。消息永远不会超过一秒或两秒，所以单个线程是可以接受的。spring-kafka文档称@Kafkalistener默认使用ConcurrentMessageListenerContainer。使用SetConcurrency控制并发的正确方法是吗？

我有一个调查多个主题的消费者。对于这个问题，我限制了每个主题一个分区。假设当消费者开始轮询时，每个主题都有一些数据。阅读的顺序是什么？ 是循环赛吗？它是从第一个读到下一个吗？我使用进行轮询。

我正在尝试用kafka绑定构建一个简单的云流应用程序。让我描述一下设置。1、我有一位制作人正在制作主题1 2。有一个流活页夹，经过一些处理后将主题1绑定到主题2。 我是这些技术的新手。无法弄清楚这里出了什么问题。有人能帮忙吗？

我试图弄清楚如何在Spring

我正在开发一个使用的软件。我有一个用户订阅了多个主题，我想知道是否有一个订单接收来自这些主题的消息。我在我的电脑上尝试了一些组合，但我需要确定这一点。例 null [编辑]我想指定这两个主题各有一个分区，并且只有一个生产者和一个消费者。我需要首先阅读来自第一个主题的所有消息，然后阅读来自另一个主题的消息