mirror of
https://github.com/featurebasedb/featurebase.git
synced 2026-10-06 19:07:50 +00:00
* adding kafka consumer config options (--kafka-max-poll-interval, --kafka-session-timeout, --kafka-group-instance-id, --kafka-socket-keepalive-enable, and --consumer-close-timeout) * wrapping consumer.Close() in timeout. Will wait consumer-close-timeout seconds before forcing consumer to exit * clean up logs |
||
|---|---|---|
| .. | ||
| csrc | ||
| testdata/schemas | ||
| cmd.go | ||
| cmd_delete_test.go | ||
| cmd_test.go | ||
| put.go | ||
| putsource.go | ||
| putsource_test.go | ||
| source.go | ||
| source_test.go | ||