5 commits

Author	SHA1	Message	Date
Jacob Brinlee	1046e28338	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 (cherry picked from commit 17cdc58d80)	2023-01-19 22:10:15 +00:00
tgruben	751b7a74fe	staticcheck fixes (#2278) ... (cherry picked from commit 0aa5efcc51)	2022-11-15 11:33:10 -08:00
CLoZengineer	f9ddb5d5c1	fix: updating code to meet linting requirements (#2171) ... * removes unused filesize function * removes ioutil usage * updates ioutil.ReadAll to io.ReadAll * updates ioutil.TempFile to os.CreateTemp * updates ioutil.TempDir to os.MkdirTemp * updates ioutil.ReadAll to os.ReadAll * update ioutil.WriteFile to os.WriteFile * updates ioutil.Discard to io.Discard * updates ioutil.ReadDir to os.ReadDir where applicable * removes unused code in idk * creates type to use for context value keys * replaces assert.Nil with assert.NoError for error checks	2022-09-29 12:34:29 -04:00
Fletcher Haynes	da9b57bd45	Updated dependency paths to reflect new repo location	2022-09-06 09:39:22 -07:00
Fletcher Haynes	eb06bb50ae	Updated code to latest version for open-sourcing.	2022-09-02 13:23:39 -07:00