当前位置: 首页 > 面试题库 >

producer 是否直接将数据发送到 broker 的 leader(主节点)?

夏学名
2023-03-14
本文向大家介绍producer 是否直接将数据发送到 broker 的 leader(主节点)?相关面试题,主要包含被问及producer 是否直接将数据发送到 broker 的 leader(主节点)?时的应答技巧和注意事项,需要的朋友参考一下

producer 直接将数据发送到 broker 的 leader(主节点),不需要在多个节点进行分发,为了

帮助 producer 做到这点,所有的 Kafka 节点都可以及时的告知:哪些节点是活动的,目标

topic 目标分区的 leader 在哪。这样 producer 就可以直接将消息发送到目的地了

 类似资料:
  • 我想知道是否有一种方法可以从HTML中的文本框中获取一些内容,将其输入到flask,然后用Python解析这些数据。我想这可能涉及一些JS但我可能错了。有什么想法吗?

  • 我正在使用PHP、HTML5和JavaScript。 我正在制作一个网页(将链接到数据库)。我试图检查标签中是否有输入,这是可行的,但当点击按钮时,即使标签中没有输入,它也会转到下一页并发送数据。 在输入所有标签之前,您应该一直停留在页面上。它还提供了一条有效的错误消息。 我是否可以在javascript中插入一些内容,以便它转到下一页并发送数据(如method=“GET”) 我以前从来没有将数据

  • 我试图使用pyspark将每日批次的数据发送到Kafka主题,但我当前收到以下错误: Traceback(最近的最后一次调用): File", line 5, in File"/usr/local/rms/lib/hdp26_c5000/park2/python/pyspark/sql/readwriter.py", line 548, in保存自己。_jwrite.save()File"/usr

  • 我们在一台服务器上托管了一个Hazelcast集群,在同一地区的不同服务器上的不同应用程序使用Hazelcast Jet客户端实例使用管道聚合来自Kafka源的数据。 在这个设置中,Jet client实例是否发送它从Kafka源Hazelcast集群接收的数据,这将涉及大量的IO?或者当我们创建管道时,Hazelcast集群本身创建到Kafka的连接,这个连接来自Jet集群而不是客户端应用程序?

  • 问题内容: 尽管JVM会将SIGTERM和类似的信号转换为关闭挂钩,但是许多服务关闭脚本使用TCP端口启动关闭。(例如,Tomcat的关闭端口,Java Service Wrapper ,JBoss的管理接口等) 所以我认为不建议使用信号和关闭钩子来正常关闭Java服务,直到发现Play!框架通过关闭钩子管理服务生命周期,并且由生成的启动脚本假定将信号发送到JVM的PID。 我知道信号是与平台相关

  • 问题内容: 我在这个jar中制作了一个名为 GetOfferSoftware的* jar 文件,我有一个名为 Offer的 Main类, 并且该Offer类包含以下功能 *** 现在我想从 另一个 与GetOfferSoftware jar不相关的 Java程序 调用此函数,所以我的问题是如何从另一个Java类访问参数并将参数发送到getOffer()函数。伙计们先谢谢 问题答案: 为了使用另一个