Kafka客户端连接池
执行kafka客户端的生产者/消费者连接池有意义吗？
kafka是否在内部维护已初始化并准备好使用的连接对象列表？
我们希望最小化连接创建的时间，这样在发送/接收消息时就不会有额外的开销。
目前，我们正在使用apache共享池库GenericObjectpool来保持连接。
任何帮助都将不胜感激。
共有1个答案
Kafka客户端维护自己与集群的连接。
生产者和消费者都保持着与他们互动的经纪人之间的联系。如果他们在连接后停止交互。最大空闲时间。ms连接将被关闭。代理上也存在此设置，因此如果管理员更改了此值，您可能需要与管理员进行验证。
因此，在大多数情况下，一旦启动Kafka客户端，就不会创建许多新连接，而只使用启动时创建的连接
-
在Netty中创建客户端连接时，我有一个问题。 这里，为什么我们没有一个bind方法，将通道绑定到发起客户端连接的端口（在客户端）？我们唯一需要提供的就是给出服务器地址和端口如下： 这是在客户端还是服务器端创建了一个新的通道？此通道绑定在客户端的哪个端口？ 我们在执行服务器端引导时进行绑定，如下所示 我很困惑，不明白客户端从哪个端口向服务器发送数据，使用的是什么通道？
-
问题内容： 我正在设计一个将Redis用作数据库的Web服务，并且我想了解使用Redis与StackService客户端连接的最佳实践。 关键是我一直在阅读有关Redis的文章，发现与服务器交互的最佳方法是使用单个并发连接。 问题是，尽管每当Web客户端向Web服务发出请求时，我都会使用 PooledRedisClientManager ，但我又获得了一个到Redis服务器的连接客户端（打开的连接
-
我试图理解netty http客户端连接池。如果是NIO和异步的，那么这个连接池的意义是什么？ 例如：如果服务A调用服务B，并且服务A的客户端连接池计数设置为50，那么这是否意味着我们最多只能发出50个并行请求？ 更新： 我在3.5秒内完成了所有通话。理想情况下，有一个连接，我应该在150秒内完成。
-
我想在由安全kafka集群的kafka主题支持的Flink SQL表上执行一个查询。我能够以编程方式执行查询，但无法通过Flink SQL客户端执行。我不知道如何通过Flink SQL客户端传递JAAS配置（）和其他系统属性。 FlinkSQL以编程方式查询 这很好。 通过SQL客户端Flink SQL查询 运行此命令将导致以下错误。 中没有任何内容，除了以下注释 SQL客户端运行命令 Flink
-
我想知道以下问题的答案： 1）如果Ignite服务器重新启动，我需要重新启动客户端（web应用程序）。是否有任何方法可以在服务器重新启动时重新连接到服务器。我知道当服务器重新启动时，它分配了一个不同的ID，因此当前现有的连接变得过时。是否有方法克服这个问题，如果是的话，哪一个版本的Ignite支持这个功能。目前我使用1.7版本 3）如果我有一个大对象要缓存，我发现序列化和反序列化在Ignite中需
-
我对Google Cloud Bigtable做了一个负载测试，制作了一个虚拟的web应用程序，用于处理向Bigtable写入数据和从Bigtable读取数据的请求。一开始，我只使用一个Bigtable连接作为单例，并跨所有线程（请求）重用它。当我增加请求数量时，我注意到性能正在变慢。不知何故，我没有增加节点的数量，而是想到了创建多个Bigtable连接，然后将它们随机分配给任何线程，从而提高了性