| 69 | } |
| 70 | |
| 71 | type syncProducer struct { |
| 72 | producer *asyncProducer |
| 73 | wg sync.WaitGroup |
| 74 | } |
| 75 | |
| 76 | // NewSyncProducer creates a new SyncProducer using the given broker addresses and configuration. |
| 77 | func NewSyncProducer(addrs []string, config *Config) (SyncProducer, error) { |
nothing calls this directly
no outgoing calls
no test coverage detected