Pierre Villard created NIFI-4985:
------------------------------------
Summary: Allow users to define a specific offset when starting
ConsumeKafka
Key: NIFI-4985
URL: https://issues.apache.org/jira/browse/NIFI-4985
Project: Apache NiFi
Issue Type: Improvement
Components: Extensions
Reporter: Pierre Villard
It'd be useful to add support for dynamic properties in ConsumeKafka set of
processors so that users can define the offset to use when starting the
processor. The properties could be something like:
{noformat}
kafka.<topic>.<partition>.offset{noformat}
If, for a configured topic, such a property is not defined for a given
partition, the consumer would use the auto offset property.
If a custom offset is defined for a topic/partition, it'd be used when
initializing the consumer by calling:
{noformat}
seek(TopicPartition, long){noformat}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
