DefaultMaxBulkSubAwaitDurationMs is the default max bulk await duration for kafka pubsub component if the MaxBulkAwaitDurationKey is not set in the metadata.

DefaultMaxBulkSubCount is the default max bulk count for kafka pubsub component if the MaxBulkCountKey is not set in the metadata.

Kafka allows reading/writing to a Kafka consumer group.

KafkaBulkMessage is a bulk event arriving from a message bus instance.

KafkaBulkMessageEntry is an item contained inside bulk event arriving from a message bus instance.

NewEvent is an event arriving from a message bus instance.

SubscriptionHandlerConfig is the handler and configuration for subscription.

EventHandler is the handler used to handle the subscribed event.

TopicHandlerConfig is the map of topics and sruct containing handler and their config.