MCPcopy
hub / github.com/IBM/sarama / Close

Method Close

async_producer.go:49–49  ·  view source on GitHub ↗

Close shuts down the producer and waits for any buffered messages to be flushed. You must call this function before a producer object passes out of scope, as it may otherwise leak memory. You must call this before process shutting down, or you may lose messages. You must call this before calling Clo

()

Source from the content-addressed store, hash-verified

47 // shutting down, or you may lose messages. You must call this before calling
48 // Close on the underlying client.
49 Close() error
50
51 // Input is the input channel for the user to write messages to that they
52 // wish to send.

Implementers 2

asyncProducerasync_producer.go
AsyncProducermocks/async_producer.go

Calls

no outgoing calls