kafka

type Consumer struct {
	Args struct {
		// List of brokers to connect to
		Brokers []string

		// Name of the topic to read from.
		Topic string
	}
	// contains filtered or unexported fields
}

type Producer struct {
	Args struct {
		// List of brokers to connect to
		Brokers []string

		// Name of the topic to push to. This is only necessary when not
		// creating a TopicProducer.
		Topic string
	}
	// contains filtered or unexported fields
}