Apache Kafka Exactly Once事务id如何影响新的获取请求生成方法
在早期版本的Kafka中，在消费者组不匹配期间，事务id和主题分区之间应该有一次语义静态映射，事务id有可能得到不同的主题分区。
为了避免这种情况，KIP-447:Producer scalability只实现了一次语义，我从KIP-477中了解到，旧的Producer在一个新API（sendOffsetToProdcuer）的帮助下使用fetch offset调用进行了保护，所以transactio。我不是用来击剑的。
但我的怀疑是，
>
仍然是事务生产者期望事务。id如何为最新的Kafka版本选择此值？
transaction.id应该具有分区的静态映射，获取偏移Geofence仅在消费者组重新平衡期间生效？
此值对于最新版本无效吗？
请帮帮我，我正在尝试理解Kafka EoS并在生产系统中实施它。
共有1个答案
由于您使用spring-kafka标记了它，我假设您正在使用它；transactional.id现在可以针对每个实例不同（因为以前仅生产者事务需要它）。不再需要将id绑定到组/主题/分区，并且需要更少数量的生产者。
看见https://docs.spring.io/spring-kafka/docs/current/reference/html/#exactly-一次
代理需要2.5或更高版本。
-
说明 获取叫车请求id，没有id无法叫车 请求地址 /v1/order/Create/orderId 支持格式 {url}?k1=v1&k2=v2&k3=v3&... HTTP请求方式 Get 是否需要登录 是 关于登录授权，参见 如何登录授权 访问授权限制 暂无 请求参数 名称 类型 必选 描述 client_id string yes 申请应用时分配的AppKey access_token s
-
我正在使用openapi生成器maven插件的4.3.1版本在Java11中生成SpringBoot服务器。 对于PUT请求，我希望能够在成功时将URI返回到创建/更新的对象，并且在不成功时返回带有问题信息的纯文本。 我的API的json对于PUT请求有以下内容： 生成的API： 然而，该方法的返回类型是
-
我正在尝试使用SpringJTA-JPA-Hibernate了解事务传播的行为。 本质上，我正在尝试更新一个实体。为此，我编写了一个测试方法，其中我使用实体管理器（em）查找方法获取对象（所以现在这个对象是管理对象）。更新获取的对象的属性。然后可选地调用正在调用em.merge的服务层（服务层传播=必需） 现在我这里有三个变体： > < li> 测试方法没有事务注释。更新提取的对象的属性，不调用服
-
问题内容： 我想知道Id更新面板使用JavaScript初始化请求。我编写了此脚本，但返回了。 不为null，它返回但我如何获得？ 编辑1） 我认为当它在里面不起作用时，这是我的代码： 和： 和后面的代码： 问题答案： 您可以使用，该返回的数组包含将要更新的UpdatePanels的ID。 http://msdn.microsoft.com/en- us/library/ee224805.aspx
-
我想知道如何从贝宝API v2获取交易ID。 我已经通过PayPal API v2创建了一个订单(https://developer.paypal.com/docs/api/orders/v2/)并成功地捕获了它。订单的状态为“已完成”，订单已出现在我的PayPal沙箱帐户中的活动中，如我所料。现在我想获取捕获事务的事务ID（见图），但我无法获取它。 我通过PayPalAPI获得订单的详细信息，但
-
当我的请求出现在我的控制器上，executorService创建一个线程池并创建一些线程来执行某些逻辑时，我的请求返回到Browser。我的问题从这里开始，运行在服务器端的线程需要session对象，线程得到的session为null。下面是代码，请给出一些合适的解决方案，这样我就可以在请求完成后得到会话值。 @RequestMapping（值=“/expandAllController”,方法=