我使用 Java 线程构建了生产者-消费者。生产者和消费者是两个不同的类，分别指的是单链表和对象锁。

我已将 Elasticsearch 和 Logstash 作为主要组件安装。 <ol> <li>启动每 4 秒创建一次记录的 Kafka 生产者</li> <

我有一个关于 sarama Go 语言 Kafka 库的看似简单的问题：当 Kafka 代理由于空闲超时（由 <code>connections.max.id

我有一个关于 Confluent Kafka 中字节速率配额管理的问题。当我们使用像这样的配置时： <pre><code>/kafka-c

有人可以指点我以 Spring Cloud 流响应方式编写的 Kafka 生产者的示例或文档，以便在发布到 kafka 代理成功

是否可以获取已向主题发送消息的生产者列表？我正在为 C# 使用 Confluent.Kafka nuget 包。

我有一个 Kafka Producer，我在其中设置了 <code>batch.size = 1000000</code> 的配置（有效 1MB）。 我在生产者

我的 PC 上部署了 ZooKeeper 和 Kafka 服务器。我启用了 ACL、访问控制列表，我还成功添加了一个包含 IP 地

主程序启动一个任务，它是 Channel 的消费者任务。消费者任务代码是： <pre><code>while (await channelReader.W

我正在尝试使用以下代码的线程执行一些生产者消费者 poc，一轮后，两个线程都处于等待状态。 但我希

我计划构建一个向 kafka 生成消息的关键组件。我只是在想，python 多线程有什么方法可以帮助我们使用异

我是 Zuul 的新手。我有两个定义不同端口的生产者项目。但是，Zuul 总是直接指向第一个项目而不是负载

在 Java 中使用 BlockingQueue 实现生产者-消费者问题时，使用 AtomicInteger 得到奇怪的输出，其中 2 个线程产

我有两个线程在运行，其中生产者线程将具有不同类型更新的并发队列 (<a href="https://github.com/cameron314/rea

环境：Win10 + Powershell 5.1 我有一个生产者函数和一个消费者函数。我使用管道连接它们。 生产者函

我相信 3 种类型的确认，因为生产者属性仅限于领导者和生产者，我希望生产者在消费者通过 kafka 代理

这是一个 Spring + Kafka 应用程序。 kafka 配置如下。 <code>batch.size=1</code> 和 <code>linger.ms = 20000</code>。 <pr

我正在使用 Camel 来处理一个巨大的 (GB) 文件，处理/修改文件中的一些数据，最后通过 AWS-S3、FTP 或 SFTP

我正在研究限制从 Kafka 主题生成和消费的消息量的要求。 下面的文档说它将在代理级别和客户端

我们有一个系统，它通过 kafka 生产者将数据写入德鲁伊，该生产者通过 Flink 作业使用交易。此作业以 30