MCPcopy
hub / github.com/segmentio/kafka-go / batchSize

Method batchSize

writer.go:811–816  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

809}
810
811func (w *Writer) batchSize() int {
812 if w.BatchSize > 0 {
813 return w.BatchSize
814 }
815 return 100
816}
817
818func (w *Writer) batchBytes() int64 {
819 if w.BatchBytes > 0 {

Callers 2

StatsMethod · 0.95
writeMessagesMethod · 0.80

Calls

no outgoing calls

Tested by

no test coverage detected