《中邮消费金融》专题

我对Kafka是陌生的。我用spring boot创建了一个kafka消费者(spring-kafka dependency)。在我的应用程序中，我使用了consumerFactory和producerfactory beans进行配置。所以在我的应用程序中，我创建了如下的kafka消费者。 我的配置如下 所以我想并行消费，因为我可能会收到更多的消息。关于使用并行主题，我发现我需要为一个主题创建多

我有4个分区和4个消费者(例如A、B、C、D)。如何使用使用者组配置哪个使用者将从哪个分区读取数据。我用的是Kafka的春靴。

因为我是新的Kafka，所以我能够从文件中读取记录，并通过生产者将消息发送到Kafka主题，但不能通过消费者消费相同的主题。 注意：您可以从任何文本文件中读取数据，我使用的是Kafka2.11-0.9。0.0版本 这是我的密码： 下面是输出：

我想在特定时间停止对特定主题的轮询。 Spring防尘套2.X Springkafka 2.5.5 Kafka版本2.5.1 比如即使有消息进来测试题目分区，消息也是从00到01堆在分区里，没有消耗。 01点之后，我想再次使用有关TEST主题的消息。 如何暂停和恢复？

null

我创建了两个apache camel（blueprint XML）kafka项目，一个是kafka-producer（接受请求并将其存储在kafka服务器中），另一个是kafka-consumer（从kafka服务器获取ups消息并处理它们）。 这个设置对单个主题和单个消费者都很有效。然而，我如何在同一个Kafka主题中创建单独的消费者组？如何在不同的消费者群体中路由同一主题中的多个消费者特定消息

本文向大家介绍Spring-cloud 服务发现与消费(以ribbon为例)，包括了Spring-cloud 服务发现与消费(以ribbon为例)的使用技巧和注意事项，需要的朋友参考一下 说明： ribbon是spring-cloud中作为服务消费者的一种角色，客户端可以通过它来对服务提供者的服务进行消费， 比如本例中是服务提供者注册到注册中心，服务提供者提供了一个服务接口，返回一个hello字符

我有两个线程的问题，似乎没有正确同步。我基本上有一个布尔值名为“已占用”。当没有线程启动时，它被设置为false。但是当一个线程启动时，线程集被占用是真的，我有一个类，它有线程（run），它们调用下面的函数。 这是一个模拟银行的示例，它接收一个金额（初始余额），然后随机执行取款和存款。我的教授提到了一些关于从取款线程到存款线程的信号？这是怎么回事？在提取线程中，它应该运行到余额为2低，并等待存款线

跟进这个问题——我想知道消费者组和偏移过期之间的语义学。总的来说，我很想知道，kafka协议如何确定一些特定的偏移量（对于消费者组、主题、分区组合）过期？它是基于作为组协议一部分的消费者的定期提交，还是在所有消费者被视为已死/关闭后应用？我认为这可能会在处理数据不经常生成的主题分区时产生影响。在我的例子中，我们有一个来自相当主题的消费者组读取（产生的数据不多）。由于消费者组不定期提交任何偏移量，我

Kafka消费者是否一直在检查代理（Kafka服务器）的运行状况，反之亦然 让我们说，无论如何，消费者和经纪人都知道彼此的健康状况，那么消费者将如何准确地从分区中读取 假设一个主题有48个分区，该主题有两个使用者组，那么有多少线程将使用所有分区中的数据

我有一个用例，在这个用例中，我有3个Kafka消费者向一个主题写作，每个消费者中的消息都需要按顺序处理。在这种情况下，如果某个消费者中存在延迟，则需要更早处理的消息将被丢弃（写入条件）。那么，有没有一种方法可以维持这些消息的顺序呢。

如何提高Kafka消费者的绩效？我有（并且需要）至少一次Kafka消费语义学 我有以下配置。processInDB（）需要2分钟才能完成。因此，仅处理10条消息（全部在单个分区中）就需要20分钟（假设每条消息2分钟）。我可以在不同的线程中调用processInDB，但我可能会丢失消息！。如何在2到4分钟的时间窗口内处理所有10条消息？ 下面是我的Kafka消费者代码。

更新： 根据答案，下面的配置在绑定器级别工作。

最近，在一次采访中，我被问到一个关于Kafka流的问题，更具体地说，面试官想知道为什么/什么时候您会使用Kafka流DSL而不是普通的Kafka消费者API来读取和处理消息流？我不能给出一个令人信服的答案，我想知道使用这两种流处理风格的其他人是否可以分享他们的想法/意见。多谢了。