You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Luigi Berrettini (Jira)" <ji...@apache.org> on 2020/09/25 08:31:00 UTC

[jira] [Commented] (KAFKA-10523) Allow to provide producer ID

    [ https://issues.apache.org/jira/browse/KAFKA-10523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17201992#comment-17201992 ] 

Luigi Berrettini commented on KAFKA-10523:
------------------------------------------

I saw that an ID can be provided for transactions: supposing I need to publish only on one topic would idempotence be guaranteed across producer restarts calling producer.initTransactions() and the performing the send out of the transaction (i.e. without calling begin or commit).

Essentially I would use producer.initTransactions() just to acquire the same PID so that I have idempotency across restarts.

> Allow to provide producer ID
> ----------------------------
>
>                 Key: KAFKA-10523
>                 URL: https://issues.apache.org/jira/browse/KAFKA-10523
>             Project: Kafka
>          Issue Type: New Feature
>            Reporter: Luigi Berrettini
>            Priority: Minor
>
> I read about the implementation of idempotence and saw that it is only guaranteed within a producer session, since it depends on a PID reassigned every time the producer (re)start.
> The PID is probably assigne relying on ZooKeeper, but I was wondering if it could be possible to support providing a PID externally to gain idempotence across restrarts e.g. having the producing application read the PID from a configuration file.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)