Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- go build && ./marvin audit kafka
- {[172.16.9.32:9092 172.16.9.33:9092 172.16.9.34:9092] marvin map[audit:TAudit]}&config.Config{
- Kafka: struct { Brokers []string "mapstructure:\"brokers\""; GroupID string "mapstructure:\"group_id\""; Topics map[string]string "mapstructure:\"topics\"" }{
- Brokers: {"172.16.9.32:9092", "172.16.9.33:9092", "172.16.9.34:9092"},
- GroupID: "marvin",
- Topics: {"audit":"TAudit"},
- },
- }
- kafka.ReaderConfig{
- Brokers: {"172.16.9.32:9092", "172.16.9.33:9092", "172.16.9.34:9092"},
- GroupID: "marvin",
- Topic: "TAudit",
- Partition: 0,
- Dialer: (*kafka.Dialer)(nil),
- QueueCapacity: 0,
- MinBytes: 10000,
- MaxBytes: 10000000,
- MaxWait: 0,
- ReadLagInterval: 0,
- GroupBalancers: nil,
- HeartbeatInterval: 0,
- CommitInterval: 1000000000,
- SessionTimeout: 0,
- RebalanceTimeout: 0,
- RetentionTime: 0,
- Logger: (*log.Logger)(nil),
- ErrorLogger: (*log.Logger)(nil),
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement