[ 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)