Implement Realtime Trigger

[iNikitaGricenko]

What changes are being made and why?

• Implemented Consume stream method (async method)
• Implemented Realtime Trigger
• Added test for Realtime Trigger

• Changed Trigger test

How the changes have been QAed?

triggers:
  - id: watch
    type: io.kestra.plugin.azure.eventhubs.RealtimeTrigger
    interval: PT10S
    eventHubName: "{{ globals.azure.eventhubs['eventhub-name'] }}"
    connectionString: "{{ globals.azure.eventhubs['connection-string'] }}"
    bodyDeserializer: STRING
    consumerGroup: "$Default"
    checkpointStoreProperties:
      containerName: "{{ globals.azure.eventhubs.checkpointstore['container-name'] }}"
      connectionString: "{{ globals.azure.eventhubs.checkpointstore['connection-string'] }}"