feat: allow to override queue buffering max messages via flag

fix: set enableAutoOffsetStore for consumer

fix: fix wrong mapping kafkaProducerConfig in streamer

fix: update log

chore: log error

fix: use maxWaitingSecondsForNewMessage from argument instead of hard…

…code

chore: Allow configuring fetch.message.max.bytes and queued.max.messa…

…ges.kbytes for kafka consumer

chore: add .gitignore

feat(exporter): Support exporting data to Google Cloud Storage

refactor: refactor main.go