EventStreaming - task-based