EventBuffer with event buffer option.

NewPublisher new a kafka publisher.

NewSubscriber new a kafka subscriber.

ReadTimeout with read timeout option.

RequiredAcks with required acks option.

WriteTimeout with write timeout option.

RequireAll the producer will consider the write successful when all of the in-sync replicas receive the record.

RequireNone the producer won’t even wait for a response from the broker.

RequireOne the producer will consider the write successful when the leader receives the record.

ErrEventFull is a message event chan full.

PublisherOption is a publisher options.

SubscriberOption is a subscriber option.