NewKafkaPublisher creates an instance of KafkaPublisher.

NewKafkaSubscriber creates an instance of KafkaSubscriber.

NewRedisPublisher creates an instance of RedisPublisher.

NewRedisSubscriber creates an instance of RedisSubscriber.

KafkaPublisher is responsible to publish message to Kafka.

KafkaSubscriber is responsible to subscribe message from Kafka.

RedisPublisher is responsible to publish message to Redis.

RedisSubscriber is responsible to subscribe message from Redis.

Reader defines a little interface for Kafka reader/subscriber functionality.

Writer defines a little interface for Kafka writer/publisher functionality.