File tree Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Expand file tree Collapse file tree 1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change @@ -228,6 +228,10 @@ err = producer.BatchSend(messages)
228
228
- accepts an array messages as parameter
229
229
- is synchronous
230
230
231
+ Close the producer:
232
+ ` producer.Close() ` the producer is removed from the server. TCP connection is closed if there aren't </b >
233
+ other producers
234
+
231
235
### ` Send ` vs ` BatchSend `
232
236
233
237
The ` BatchSend ` is the primitive to send the messages, ` Send ` introduces a smart layer to publish messages and internally uses ` BatchSend ` .
@@ -349,6 +353,9 @@ Disabling the CRC control can increase the performances.
349
353
350
354
See also "Offset Start" example in the [ examples] ( ./examples/ ) directory
351
355
356
+ Close the consumer:
357
+ ` consumer.Close() ` the consumer is removed from the server. TCP connection is closed if there aren't </b >
358
+ other consumers
352
359
353
360
### Manual Track Offset
354
361
The server can store the offset given a consumer, in this way:
You can’t perform that action at this time.
0 commit comments