我有一个带有以下代码的Kafka客户端 final Map<String, Object> configsAdminClientConfig.BOOTSTRAP_SERVERS_CONFIG, "server-ip"); }
此方法由多个线程调用，并创建多个管理客户端所以我想把它保存在一
浏览 7提问于2020-03-02得票数 0
这是否意味着从多线程调用这些方法是可以的？我想与这里的专家确认，以避免生产中的任何问题
浏览 3提问于2020-05-04得票数 2
2回答
我想知道是否有可能读取和处理多个消息由Kafka消费者(Java客户端)并行..I意味着使用多线程...我应该使用rxJava吗?？3)并希望使Java客户端作为守护服务运行在Linux中，这样它就可以连续运行，轮询Kafka的消息，读取和处理相同的..is这是
浏览 0提问于2016-02-24得票数 0
1回答
将此操作并行化的最佳方法是什么？例如，假设我创建了1000个分区。如果为我的主题生成1,001+消息，则将发出前1,000个请求，但之后的每条消息都将排队，直到该分区中的前一个请求完成为止。我考虑过让http请求是异步的</
浏览 3提问于2015-05-08得票数 1
回答已采纳
如何使用java为kafka 0.10.1.x创建无zookeeper依赖的kafka topic？我见过创建主题的线程，但它使用zookeeper，zk客户端等。我想只使用java，没有scala依赖，因为kafka 0.10已经不使用zookeeper。
浏览 1提问于2017-12-11得票数 0
我创建了一个3节点的ZK组合，作为Kafka和(潜在的)其他服务的共识集群。我现在想让我的Kafka经纪人需要TLS/ SSL，这样Kafka客户端必须通过SSL证书进行通信。但我不想将我的3
浏览 5提问于2016-10-13得票数 0
回答已采纳
使用Python-kafka管理客户端，我知道如何创建和删除主题。
但是有没有办法检查这个话题是否存在呢？如果不是，那么只有我想创建它。我如何在python -kafka管理客户端中做到这一点？我在文档中没有看到任何东西。
浏览 3提问于2020-08-18得票数 0
我正在尝试使用ZKStringSerializer类，这是我通过根据整个互联网，甚至在我被计算机重启之前我自己的代码，这应该可以让我的代码工作这很让人困惑，因为这个文件不应该在任何包中，而且我也没有在任何地方指定包。这是我的代码：import org.apache.spark.sql.functions._
import org.apache.l
浏览 7提问于2018-07-03得票数 1
多个生产者可以共享conf的可耻副本吗？如果您不能共享相同的dr_cb副本，是否可以共享相同的conf？
浏览 27提问于2016-09-15得票数 0
在我们的项目中，我们需要通过许多线程定期从第三方获取数据，然后将这些数据推送给Kafka。如果目前无法使用Kafka服务器，则应该终止流，在下一次预定执行过程中应该丢失并重新获取获取的数据。此外，还需要使用事务管理，因为我们需要将这批消息发送给Kafka到不同的主题。如果没有发送一条消息，则所有其他消息都应该回滚。
如果Kafka Server不可用，我们就遇到了终止执行的问题。当事务管理<
浏览 1提问于2018-07-16得票数 2
1回答
我是一个事件驱动的数据体系结构的初学者，使用Kafka / WebSocket作为核心(目前是Kinesis)，并且我有一些关于如何在这种结构上构建一个API的问题。我的具体用例是，我有大约4种不同的数据流进入Kinesis，经过一些处理后，我将它们组合成一个“聚合流”，然后将该流的结果存储到一个分布式DB中，以用于历史目的。API应该直接使用Kinesis流并将消息中继到客户端吗？还是最好在Kinesis流和API
浏览 0提问于2018-03-19得票数 1
1回答
我可以使用KafkaConsumer在单独的线程中使用消息。multiprocessing.Process而不是threading.Thread时，我会得到一个错误：这个和建议使用多处理并行地使用消息是可能的。不好意思，原来的代码太复杂了，所以我在这里创建了一个示例，希望能够告诉您正在发生的事情。job.start()
job.join()
if __name__ == "
浏览 3提问于2017-09-29得票数 4
回答已采纳
我试图测试运行一个卡夫卡节点与3个经纪人和动物园管理员。我希望使用控制台工具进行测试。我以这样的方式经营制片人：然后，我以这样的方式运行消费者：
kafka-console-consumer --zookeeper localhost:2181 --topic testTopic --from-beginni
浏览 2提问于2017-01-21得票数 16
回答已采纳
2回答
我有一个基于spring的应用程序，需要在Kafka上使用/生成事件。我对图书馆的选择犹豫不决。直接使用Kafka客户端似乎很简单，而不必管理spring和Kafka客户端之间的兼容性矩阵：
另一方面，使用spring可以帮助项目规范使用Kafka的配置属性，并为测试添加嵌入式kafka。在弹簧靴上使用spring，而不是直接使用kafka-客
浏览 3提问于2020-01-11得票数 7
回答已采纳
我很好奇Confluent的Kafka REST代理和生产者/消费者在kafka官方客户库中实现的优缺点。我知道Confluent的Kafka REST代理用于管理任务和不受kafka客户端支持的语言。
那么，卡夫卡客户的优势是什么呢？
浏览 1提问于2018-06-29得票数 4
回答已采纳
Kafka制作人需要一个kafka经纪人的引导列表才能工作。根据，它需要能够连接到其中一个代理，然后获取关于集群中所有实时代理的元数据。现在，所有的代理都已经在Zookeeper中注册了，Kafka消费者连接到ZK，ZK处理哪个代理，哪个分区是要读取的数据。既然ZK已经有了所有的信息，为什么制片人不能连接到ZK呢？我看到有一些关于这方面的问题，但他们似乎解释了为什么消费者需要ZK &而不是为什么生产者需要经纪人的引导列表而不是ZK？
浏览 0提问于2016-03-01得票数 5
我正在为使用Kafka和Flink等工具的多个用户建立一个用于缓存数据库查询的数据流管道，我对何时需要实现多线程感到困惑。
我已经构建了一个包含使用Vertx的HTTP服务器的用户服务。我为此创建了一个"kafka客户机“，并且在每个用户请求到端点时，我创建了这个kafka客户机的一个新实例来发送请求。如果我为每个传入的用户请求创建这个kafka客户端的
浏览 11提问于2022-06-24得票数 1
回答已采纳
我使用的是卡夫卡0.10.1版。我通过SSL和它的工作fine.Now连接了Kafka代理及其客户端，我有一个带有一些限制的查询。我的局限性是
之间的联系卡夫卡经纪人和动物园管理员通过SASL (因为动物园管理员不支持SSL)。我有一个疑问，如果在Kafka-Broker<
浏览 0提问于2017-10-24得票数 0
我正在尝试安装Zookeeper和Kafka作为基本测试，并且必须将中的客户端端口更改为可用/打开的端口，如下所示，# the port at whichthe clients will connect但是，即使在启动Kafka服务器时，在动物园管理员属性文件中更改了它，它也尝试连接到默认的2181端口，如下所示，
浏览 0提问于2018-09-26得票数 0
回答已采纳
我很困惑地看码头-撰写文件，所以我想问我的问题在这里。在大多数示例中，我看到这样的配置： image: confluentinc/cp-enterprise-kafka:5.3.1我想了解几件与此相关的事情：配置代理的
浏览 2提问于2020-10-08得票数 5
回答已采纳
云服务器
ICP备案
对象存储
云直播
腾讯会议
腾讯云开发者
