Kafka客户端连接池

文章/答案/技术大牛

发布

1回答

java、apache-kafka

执行kafka客户端的生产者/消费者连接池有意义吗？ kafka是否在内部维护已初始化并准备使用的connection对象列表？

浏览 17提问于2017-03-14得票数 11

回答已采纳

1回答

生产者连接池- Kafka

java、apache-zookeeper、apache-kafka

我不能理解kafka是如何为生产者维护到代理的连接池的。producer = new Producer<Integer, String>(new ProducerConfig(props));它会返回连接池中的连接吗kafka中维护生产者连接池的设置在哪里？

浏览 4提问于2014-08-22得票数 2

1回答

集成kafka和Odoo

database、postgresql、apache-kafka、odoo

我在aws ec2实例上有Odoo前端，并通过15个并发连接将其与站点上的postgresql连接，因此我想确保此连接限制不会造成问题，所以我想使用kafka而不是Odoo直接执行数据库写入，但在网上找不到任何资源来帮助我解决问题

浏览 0提问于2020-10-26得票数 0

1回答

Spark结构化流前置分区/连接池问题

apache-spark、spark-structured-streaming

我正在使用结构化流从Kafka读取数据，我需要将数据保存到InfluxDB。._2) ) } logger.info("Started Spark-Kafka streaming session") 并且工作人员无法获得连接池对象。有什么明显的事我在这里失踪了吗？

浏览 0提问于2018-05-17得票数 2

1回答

Azure函数支持连接池或以任何其他方式重用相同的数据库实例

azure、azure-functions

As AWS Lambda支持连接池，如所示。根据我的要求，我将使用kafka的触发器函数。但是对数据库的请求会频繁发生，以至于它会占用很高比例的cpu。因此，为了避免这种情况，我希望使用连接池或任何其他方式来使用相同的数据库上下文实例。

浏览 1提问于2021-03-25得票数 0

1回答

Spring中的套接字连接数

spring、sockets、apache-kafka、spring-kafka、connection-pooling

我试着理解当使用春季卡夫卡连接到Kafka时，套接字连接是如何打开的。下面的代码连接到一个名为test的Kafka主题，该主题有32个分区。application.yml kafka: consumer:: org.apache.kafka.common.serialization.StringDeserializer spring.kafka.consumer.value-des

浏览 4提问于2022-03-27得票数 0

1回答

如何禁用Netty HTTP客户端连接池？

spring-boot、spring-security、spring-cloud-gateway、reactor-netty

Spring Security OAuth2LoginAuthenticationWebFilter使用Netty HTTP客户端向身份提供者发送请求。Netty有一个连接池，由于负载均衡服务器在Netty和身份提供商之间搞乱了连接池，从而断开了池中的空闲连接。有没有办法在Spring Security中禁用Netty HTTP客户端连接池？我尝试配置Spring Cloud Gateway HTTP客户端参数，但它不影响Spring Security使用的Netty HTTP客

浏览 2提问于2019-12-18得票数 1

1回答

弹性高级Rest客户端需要我自己在应用中实现连接池吗？

elasticsearch、connection-pooling、resthighlevelclient

在我的应用程序中，我使用高级rest客户端作为我的java客户端，并在我的业务服务代码中通过自动连接highRestClient来使用它，这与在数据库连接中使用某些连接池没有什么不同。目前，它的性能还可以，但是我想知道客户端的底层实现是否使用了某种类型的连接池。如果没有，是否需要单独使用高级rest客户端来实现连接池以提高其性能？

浏览 6提问于2022-01-04得票数 0

2回答

如何通过glassfish中已部署的应用程序定义不同的连接池

java、mysql、jakarta-ee、glassfish、jpa-2.0

我使用的是glassfish 4和java EE 7，我需要为将要在glassfish中部署的每个应用程序定义一个不同的连接池。我的每个客户端都有一个应用程序(.war文件)，并且每个客户端在mysql数据库中都有自己的用户/密码/模式，因此数据不会在客户端之间共享。我知道如何在glassfish中定义连接池，但是我的所有应用程序都只能使用相同的设置(我使用bonecp btw)。我希望能够为部署的每个应用程序更改用户/密码/模式。是否可以在persistence.

浏览 0提问于2014-11-22得票数 2

1回答

kafka云流:创建生产者绑定失败，30秒后重试

spring、apache-kafka、apache-kafka-streams、spring-kafka、spring-cloud-stream

我想通过转换接口来处理一个kafka流。:118) ~[spring-cloud-stream-binder-kafka-streams-3.0.8.RELEASE.jar:3.0.8.RELEASE] at org.springframework.cloud.stream.binder.kafka.streams.KStreamBinder.doBindProducer$SingleWaiter.await(KafkaFutureImpl.java:108) ~[kafka-clients-2.3.1.jar:n

浏览 55提问于2020-11-04得票数 1

1回答

用于SOAP客户端的Apache监视

soap、jax-ws、cxf、jmx、java-metro-framework

文档中没有提到它是否适用于SOAP客户端。另一方面，Metro明确表示，客户端监控也是受支持的。我看到CXF的唯一原因是它提供连接池，而据我所知，Metro并没有提供连接池。所以我的问题是，有人知道CXF是否支持SOAP客户端的客户端JMX监控吗？如果是的话，你能给点建议吗？如果没有，是否有一种方法可以实现与Metro的连接池？

浏览 3提问于2014-01-14得票数 1

回答已采纳

2回答

如何在夸夸斯微配置箱中配置rest客户端

quarkus、microprofile

当使用作为rest客户端时，如何配置底层HttpClient？比如重试次数、每个主机的连接池大小等等？另外，是否有可能以某种方式强制客户端重新启动(因此连接池将被重新启动)？

浏览 9提问于2020-09-08得票数 3

回答已采纳

1回答

Netty连接池

java、client、netty

Netty连接池我想知道哪些选项或如何在netty中实现客户端连接池。

浏览 2提问于2013-02-19得票数 0

4回答

我可以更改Python的"requests“模块的连接池大小吗？

python、multithreading、request、python-requests

这是否表明我的客户端的连接池已满？或者服务器上的连接池已满，这是给我的客户端的错误吗？)我可以做什么来增加请求连接池的大小

浏览 1提问于2013-08-27得票数 60

1回答

设计问题-为来自应用程序的不同类型的出站呼叫配置连接池

connection-pooling、reactor-netty

HTTPHTTPSHTTPS与mSSL 应该为所有应用程序设置一个连接池，还是应该在每个客户端/出站连接上使用不同的连接池，因为SSL上下文是通过证书在连接池上配置的？如果我有一个连接池，也不会使用配置在连接池上的SSL上下文进行HTTP调用。

浏览 1提问于2021-08-16得票数 0

1回答

为什么我们的Upsolver Kafka数据源试图连接到连接中未定义的代理/节点主机？

apache-kafka、sqlake、upsolver

我们有卡夫卡数据源，它有7个代理(节点)，比如node1，node2 to node7。当创建Upsolver数据源时，连接只指定node1到node5。不加node6和node7。

浏览 15提问于2022-11-10得票数 0

回答已采纳

1回答

线程“kafka”中的未命名异常-网络-线程生成器-1

java、spring-boot、apache-kafka、spring-kafka

pom.xml中的Kafka依赖项如下所示： <groupId>org.apache.kafka</groupId></dependency> <groupId>org.apache.kafka&l

浏览 3提问于2019-11-05得票数 0

回答已采纳

2回答

kafka artifactIds kafka_2.10和kafka-clients有什么区别？

apache-kafka

以下maven对Kafka 0.9客户端API的依赖有什么不同？第1部分： <groupId>org.apache.kafka</groupId> <version>2.10.0</version>第

浏览 1提问于2016-02-01得票数 9

3回答

运行用于单元测试的java.lang.NoClassDefFoundError时的KafkaEmbedded

spring、spring-boot、spring-kafka

java.lang.NoClassDefFoundError: org/apache/kafka/common/security/auth/SecurityProtocol at kafka.utils.TestUtils.createBrokerConfig(TestUtils.scala我知道这个类"SecurityProtocol“在

浏览 2提问于2018-06-06得票数 3

回答已采纳

1回答

泽西客户端可以在多线程环境中使用rest吗？

java、rest、jax-rs、jersey-client、jersey-1.0

我想为多线程项目创建泽西客户端。是否需要为客户端创建连接池？服务器.How上有500个TPS流量，用于计算以下参数以获得最佳性能。什么是重置连接池的概念以及何时使用它？

浏览 13提问于2022-03-24得票数 2

回答已采纳

点击加载更多