[
https://issues.apache.org/jira/browse/NIFI-4595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Koji Kawamura updated NIFI-4595:
--------------------------------
Issue Type: Improvement (was: Bug)
> Add ConsumeAzureEventHub processor
> ----------------------------------
>
> Key: NIFI-4595
> URL: https://issues.apache.org/jira/browse/NIFI-4595
> Project: Apache NiFi
> Issue Type: Improvement
> Components: Extensions
> Reporter: Koji Kawamura
> Assignee: Koji Kawamura
>
> As reported by NIFI-2835, the existing GetAzureEventHub processor does not
> handle partition distribution among nodes in a NiFi cluster, and handling
> offset information across NiFi restart.
> The processor uses PartitionReceiver directly, however, there's another
> approach to receive events from Event Hub, that is using EventProcessorHost
> class.
> EventProcessorHost uses Azure Storage to store consumer group offset
> information so that it can distribute consumer load among consumer instances
> within the same group. Also this way can handle restart and NiFi cluster
> scale scenario better.
> In addition to above enhancements, we could also add Record data model
> capability to new ConsumeAzureEventHub. Similar to ConsumeKafkaRecord
> processor.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
