kqconfig.go 236 B

12345678910111213141516
  1. //@File kqconfig.go
  2. //@Time 2022/05/06
  3. //@Author #Suyghur,
  4. package kafka
  5. type KqProducerConfig struct {
  6. Brokers []string
  7. Topic string
  8. }
  9. type KqConsumerConfig struct {
  10. Brokers []string
  11. Topic string
  12. GroupId string
  13. }