Kafka同步发生器
我遇到了以下关于从生产者同步发送。我知道上下文生产者中的异步机制
在此将来调用get（）将阻塞，直到相关请求完成，然后返回记录的元数据或引发发送记录时发生的任何异常。
什么是真正的意思相关联的请求完成，我是相当这不是指完整的请求，但在什么程度上这个短语是指？直到经纪人？直到生产者等使用的缓冲区...？
当ack=all与同步生产者和异步生产者一起使用时，它有什么不同？两个场景都被阻塞以进行确认？
共有1个答案
生产者有一个内部队列来缓冲一些记录（基于配置linger.ms和min.batch.size）。有一个内部后台线程请求代理（领导分区所在的地方）发送批处理数据。根据配置max.connections.in.flight，生产者可以并行地拥有多个请求。这意味着"关联请求"。
当ack=all与同步生产者和异步生产者一起使用时，它有什么不同？两个场景都被阻塞以进行确认？
get方法将阻塞，直到对代理的请求完成，这意味着它收到了基于确认设置的所有确认。
使用get方法总是会导致同步生产者。
-
如何在Kafka中发送同步消息 实现这一点的一种方法是设置properties参数 。 但是我想知道是否有一种甚至直接或替代的方式在Kafka中发送同步消息。（比如producer.sync发送（...）等等）。
-
同步（Synchronization） 线程间的通信主要是通过共享访问字段以及其字段所引用的对象来实现的。这种形式的通信是非常有效的，但可能导致2种可能的错误：线程干扰（thread interference）和内存一致性错误（memory consistency errors）。同步就是要需要避免这些错误的工具。 但是，同步可以引入线程竞争（thread contention），当两个或多个线程
-
问题内容： 我是在Java中使用wait（）和notify（）的新手，并且遇到了IllegalMonitorStateException。 主要代号 我收到一个IllegalMonitorStateException，称为state.notify（）。有任何想法吗？ 编辑 ：根据下面的答案是有效的代码。作为附带说明，我首先尝试使用与使用Integer相同的问题的枚举进行此操作。 问题答案： 这个
-
问题内容： 这个问题已经在这里有了答案 ： 在一致之前如何理解发生的事情 （4个答案） 2年前关闭。 我试图理解Java 发生在订单概念之前的事情，并且有些事情似乎非常令人困惑。据我所知，之前发生的只是一系列动作的顺序，并不提供有关实时执行顺序的任何保证。实际上（强调我的）： 应该注意的是，两个动作之间存在先发生关系并不一定意味着在实现中它们必须按照该顺序进行。 如果重新排序产生的 结果与合法执行
-
我们有一个包含对象集合的开发服务器。这些对象的实际积累是一个持续的过程，在这个本地开发服务器上运行标签、验证等的整个过程。一旦这些对象准备好生产，它们就会被添加到生产数据库中，从那时起，生产数据库将在其计算中使用它们。 我正在寻找一种简单地将增量（新对象）添加到生产数据库中的方法，同时将所有其他集合和旧对象保留在同一个集合中。到目前为止，我们一直使用MySql，所以这个过程只涉及运行数据库结构和数
-
我目前正在探索Kafka，作为一个简单问题的初学者。 将有一个生产者向一个主题推送消息，但将有n个spark应用程序的消费者从kafka发送消息并插入到数据库中(每个消费者插入到不同的表中)。 是否有可能消费者会不同步（例如消费者的某些部分会停机很长一段时间），然后一个或多个消费者不会处理消息并插入到表中？ 假设代码总是正确的，在按摩数据时不会出现异常。重要的是每条消息只处理一次。 我的问题是，K