学习apache-kafka－开发者之家

问题描述这是question的续集。我可以把"普通"的阿帕奇卡夫卡活页夹和功能模型一起使用吗？到目前为止，使用基于注释的配置，我在一个应用程序中混合了spring-cloud-stream-binder-kafka和spring-cloud-stream-binder-kafka

问题描述我知道如何使用命令式编程方法定义生产者，但我找不到如何使用函数式编程方法定义生产者。我读了关于这个的SpringCloudStreamBinder文档，但只找到了如何定义消费者，或者消费者和生产者(例如，从主题中获取信息，转换数据并发送到另一个主题)。所以，我不知道是否可

问题描述由于下面的错误，我无法启动Kafka服务器。java.io.IOException:Mapfailedatsun.nio.ch.FileChannelImpl.map(FileChannelImpl.java:940)atkafka.log.AbstractIndex.<

问题描述我一直在为PostgreSQL实现一个Kafka连接器(我正在使用debeziumKafka连接器并通过docker运行所有组件)。我需要一个定制分区键，所以我一直使用SMT来实现这一点。但是，我使用的方法创建了一个Struct，并且我需要它是一个字符串。这篇articl

问题描述在我的SpringBootKafka发布应用程序中，我希望提供对以字符串(Json)或字节格式发布消息的支持，因为我希望同时支持json和avro。但是春装中的卡夫卡模板让我们只能定义其中的一个模板。有没有办法同时使用两个模板或任何其他方式来同时支持JSON和Avro？K

问题描述我希望使用SpringKafkaAPI实现有状态监听器。提供以下信息：ConCurrentKafkaListenerContainerFactory，并发设置为"n"Spring@Service类上的@KafkaListener批注方法然后创建"n"个KafkaMessa

问题描述我正在尝试将StreamsUncaughtExceptionHandler添加到我的Kafka流处理器中。该处理器是用Kafka函数编写的。我查看了suggestionprovidedbyArtemBilan以将StreamsUncaughtExceptionHandle

问题描述我正在尝试KafkaStreams的字数统计问题。我正在使用带有Scala版本2.11.12和SBT版本1.1.4的Kafka1.1.0。我收到以下错误：Exceptioninthread"wordcount-application-d81ee069-9307-46f1-

问题描述默认情况下，.windowedBy(SessionWindows.with(Duration.ofSeconds(60))为每个传入记录返回一条记录。结合使用.count()和.filter()可以轻松检索第一条记录。使用.suppress(Suppressed.unti

问题描述我有一个Kafka流--比如博客和Kafka表--比如那些博客相关的评论。Kafka流中的key可以映射到Kafka表中的多个值，即一个博客可以有多条评论。我想连接这两个对象，并创建一个带有注释ID数组的新对象。但是当我连接时，流只包含最后一个注释id。有没有任何文档或示