Documentation ¶
Index ¶
- func New(producer sarama.SyncProducer, brokers []string) kafkapb.KafkaServiceServer
- type Service
- func (s *Service) Consumer(ctx context.Context, input *kafkapb.ConsumerRequest) (*kafkapb.ConsumerResponse, error)
- func (s *Service) ConsumerStream(input *kafkapb.ConsumerStreamRequest, ...) (err error)
- func (s *Service) Producer(ctx context.Context, input *kafkapb.ProducerRequest) (*kafkapb.ProducerResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func New ¶
func New(producer sarama.SyncProducer, brokers []string) kafkapb.KafkaServiceServer
Types ¶
Click to show internal directories.
Click to hide internal directories.