Package mocks is a generated GoMock package.

NewBrokerRouter creates a new message router with the given options.

NewPublisher creates a new Kafka publisher with the provided broker addresses and options.

NewSubscriber creates a new Kafka subscriber with the specified brokers and options.

WithCloseTimeout sets the close timeout for the router.

WithMarshaler sets the message marshaller for the Kafka publisher configuration.

WithPublisherOTELEnabled sets the OpenTelemetry enabled flag for the Kafka publisher.

WithPublisherSaramaConfig sets the Sarama configuration for the Kafka publisher.

WithPublisherTracer sets the tracer for the Kafka publisher configuration.

WithSubscriberConsumerGroup sets the consumer group for the Kafka subscriber.

WithSubscriberInitTopic sets the initial topic details for the Kafka subscriber.

WithSubscriberSaramaConfig sets the Sarama configuration for the Kafka subscriber.

WithSubscriberTracer sets the tracer for tracing Kafka messages.

WithUnmarshaler sets the unmarshaler for deserializing Kafka messages.

PublisherOption defines the functional option pattern for configuring the Kafka publisher.

RouterOption defines the functional option pattern for configuring the router.

SubscriberOption represents a functional option for configuring a Kafka subscriber.