-
ProcessBufferProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
OrderedMessageProcessors orderedMessageProcessors,
OutputBuffer outputBuffer,
ProcessingStatusRecorder processingStatusRecorder,
MessageULIDGenerator messageULIDGenerator,
DecodingProcessor decodingProcessor,
jakarta.inject.Provider<Stream> defaultStreamProvider,
FailureSubmissionService failureSubmissionService,
StreamMetrics streamMetrics,
ClusterConfigService clusterConfigService,
com.google.common.eventbus.EventBus eventBus)