apache-kafka
-
kafka消费者能否在从一个主题轮询所有消息之前过滤消息? 据说消费者只能阅读整个主题。没有运气对经纪人进行评估以过滤消息。 这意味着我们必须使用/接收来自主题的所有消息,并在客户端过滤它们。 这太过分了。我想知道我们是否可以根据已
-
在弹簧靴中创建KafkaTemplate的正确方法 我尝试在spring boot应用程序中配置apache kafka。我阅读了 要解决这个问题,我需要创建bean: 但是,如果我需要创建ProducerFactory手册,那么在appplication.yaml中设置有什么意义呢?
-
弹簧集成 Kafka 消费者监听器未接收消息 根据中提到的,以下是我编写配置的方式。 我花了很多时间来弄清楚为什么当主题有消息时,这个听众没有被击中,我做错了什么。 我知道我可以使用通道接收消息(我已经在代码中注释了
-
将 Kafka 输入流动态连接到多个输出流 Kafka Streams中是否内置了允许将单个输入流动态连接到多个输出流的功能? 允许基于真/假谓词进行分支,但这不是我想要的。我希望每个传入的日志确定它将在运行时流式传输到的主题,例如,
-
kafka AdminClient API 超时等待节点分配 我是Kafka的新手,正在尝试使用API来管理在我的本地计算机上运行的Kafka服务器。我的设置与Kafka文档部分完全相同。唯一的区别是我没有创建任何主题。 我在此设置上运行任何shell脚本都没有问
-
当 Kafka 关闭时,我该如何处理 IOException? 我正在尝试发布消息,而Apache Kafka已关闭。我应该如何处理这样的紧急情况? KafkaProducer::send() 方法不会引发任何可以处理的异常。生产者吞下它们并记录错误,所以我被这样的消息淹没
-
卡夫卡再平衡。重复处理问题 我有一个消费者工作者应用程序,它在内部启动了许多线程,每个线程都在生成它的KafkaCosnumer。Cosnumers具有相同的主题,并订阅了相同的主题。因此,每个消费者都能获得公平的分区份额。 如
-
Apache Flink: java.lang.NoClassDefFoundError 我正在尝试 可能出了什么问题?任何依赖项,版本? 注意:如果我注释有问题的行,程序运行没有问题。还要注意的是,此错误也出现在某些Kafka()样本上;我看到了amamaraws.kafka.samples.CustomMM2Re
-
调试自定义 Kafka 连接器的简单、有效的方法是什么? 我正在处理几个Kafka连接器,并且在控制台输出中没有看到它们的创建/部署中的任何错误,但是我没有得到我正在寻找的结果(没有任何结果,无论想要还是其他)。我基于 Kafka 的示例 FileStream
-
在kafka中创建多少个生产者? 在一个高容量的实时java web应用程序中,我正在向发送消息。目前,我正在发送到单个主题,但将来我可能需要向多个主题发送消息。 在这种情况下,我不确定是否要为每个主题创建一个生产者
标签