[jira] [Commented] (NIFI-6218) Support setting transactional.id in PublishKafka/PublishKafkaRecord

["ASF subversion and git services (JIRA)" <ji...@apache.org>]

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

ASF subversion and git services commented on NIFI-6218:
-------------------------------------------------------

Commit aefdc9377cc00c82ab70d44da5effd42da63bb04 in nifi's branch refs/heads/master from Ferenc Szabo
[ https://gitbox.apache.org/repos/asf?p=nifi.git;h=aefdc93 ]

NIFI-6218 Support setting transactional.id in PublishKafka/PublishKafkaRecord

Added new property to the processors. If it is empty, then the behaviour is the same as before.
Adde unit test to check if KafkaProducer receives the new property.

Testing Done:
Unit tests.
Connecting to kafka and verifying transactionalId-s in kafka server log.

fixing review findings

This closes #3439.

Signed-off-by: Koji Kawamura <ij...@apache.org>


> Support setting transactional.id in PublishKafka/PublishKafkaRecord
> -------------------------------------------------------------------
>
>                 Key: NIFI-6218
>                 URL: https://issues.apache.org/jira/browse/NIFI-6218
>             Project: Apache NiFi
>          Issue Type: New Feature
>          Components: Extensions
>    Affects Versions: 1.9.0
>            Reporter: Ferenc Szabo
>            Assignee: Ferenc Szabo
>            Priority: Major
>          Time Spent: 2h 10m
>  Remaining Estimate: 0h
>
> Add support for specifying *transactional.id*  within PublishKafka/PublishKafkaRecord. Currently a random UUID is utilized and generated each time the processor is scheduled.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)