Advertisement
Guest User

configs!!!!

a guest
Feb 18th, 2019
96
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.09 KB | None | 0 0
  1. go build && ./marvin audit kafka
  2.  
  3. {[172.16.9.32:9092 172.16.9.33:9092 172.16.9.34:9092] marvin map[audit:TAudit]}&config.Config{
  4. Kafka: struct { Brokers []string "mapstructure:\"brokers\""; GroupID string "mapstructure:\"group_id\""; Topics map[string]string "mapstructure:\"topics\"" }{
  5. Brokers: {"172.16.9.32:9092", "172.16.9.33:9092", "172.16.9.34:9092"},
  6. GroupID: "marvin",
  7. Topics: {"audit":"TAudit"},
  8. },
  9. }
  10.  
  11. kafka.ReaderConfig{
  12. Brokers: {"172.16.9.32:9092", "172.16.9.33:9092", "172.16.9.34:9092"},
  13. GroupID: "marvin",
  14. Topic: "TAudit",
  15. Partition: 0,
  16. Dialer: (*kafka.Dialer)(nil),
  17. QueueCapacity: 0,
  18. MinBytes: 10000,
  19. MaxBytes: 10000000,
  20. MaxWait: 0,
  21. ReadLagInterval: 0,
  22. GroupBalancers: nil,
  23. HeartbeatInterval: 0,
  24. CommitInterval: 1000000000,
  25. SessionTimeout: 0,
  26. RebalanceTimeout: 0,
  27. RetentionTime: 0,
  28. Logger: (*log.Logger)(nil),
  29. ErrorLogger: (*log.Logger)(nil),
  30. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement