[
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 <[email protected]>
> 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)
