featurebase/idk/kafka
Jacob Brinlee 17cdc58d80
SUP-288 (#2414)
* 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
2023-01-18 17:42:19 -06:00
..
csrc staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
testdata/schemas FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
cmd.go SUP-288 (#2414) 2023-01-18 17:42:19 -06:00
cmd_delete_test.go changes to add bool support in idk (#2240) 2022-10-19 12:16:38 -05:00
cmd_test.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
put.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00
putsource.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
putsource_test.go FB-1597: unifying idk and featurebase (#2160) 2022-07-28 17:23:16 -05:00
source.go SUP-288 (#2414) 2023-01-18 17:42:19 -06:00
source_test.go staticcheck fixes (#2278) 2022-11-07 10:51:55 -06:00