feat: Support for multi DB producer

[ashwin1111]

No description provided.

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
common
compression.py	5	1	80%	9
log.py	9	0	100%
utils.py	30	20	33%	17–60
common/qconnector
rabbitmq_connector.py	45	13	71%	23–24, 37–49, 52–65
consumer
event_consumer.py	34	0	100%
pgoutput_parser
base.py	61	0	100%
delete.py	14	0	100%
insert.py	15	0	100%
relation.py	27	0	100%
update.py	19	0	100%
producer
event_producer.py	148	26	82%	118–122, 215–217, 223–224, 229–235, 238–241, 244–245, 248–252
TOTAL	407	60	85%

Tests	Skipped	Failures	Errors	Time
18	0 💤	0 ❌	0 🔥	0.199s ⏱️

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
common
compression.py	5	1	80%	9
log.py	9	0	100%
utils.py	30	20	33%	17–60
common/qconnector
rabbitmq_connector.py	45	13	71%	23–24, 37–49, 52–65
consumer
event_consumer.py	34	0	100%
pgoutput_parser
base.py	61	0	100%
delete.py	14	0	100%
insert.py	15	0	100%
relation.py	27	0	100%
update.py	19	0	100%
producer
event_producer.py	148	26	82%	118–122, 215–217, 223–224, 229–235, 238–241, 244–245, 248–252
TOTAL	407	60	85%

Tests	Skipped	Failures	Errors	Time
18	0 💤	0 ❌	0 🔥	0.204s ⏱️

[Shwetabhk]

For multiple dbs this looks a little dirty
I would prefer that we get all this config from a yaml file.

Eg. what if for different producer I want different settings altogether

[Shwetabhk]

This is okay for now, but please fix this later

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
common
compression.py	5	1	80%	9
log.py	9	0	100%
utils.py	30	1	97%	35
common/qconnector
rabbitmq_connector.py	45	13	71%	23–24, 37–49, 52–65
consumer
event_consumer.py	34	0	100%
pgoutput_parser
base.py	61	0	100%
delete.py	14	0	100%
insert.py	15	0	100%
relation.py	27	0	100%
update.py	19	0	100%
producer
event_producer.py	148	26	82%	118–122, 215–217, 223–224, 229–235, 238–241, 244–245, 248–252
TOTAL	407	41	90%

Tests	Skipped	Failures	Errors	Time
30	0 💤	0 ❌	0 🔥	0.237s ⏱️

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
common
compression.py	5	1	80%	9
log.py	9	0	100%
utils.py	30	1	97%	35
common/qconnector
rabbitmq_connector.py	45	13	71%	23–24, 37–49, 52–65
consumer
event_consumer.py	34	0	100%
pgoutput_parser
base.py	61	0	100%
delete.py	14	0	100%
insert.py	15	0	100%
relation.py	27	0	100%
update.py	19	0	100%
producer
event_producer.py	148	26	82%	118–122, 215–217, 223–224, 229–235, 238–241, 244–245, 248–252
TOTAL	407	41	90%

Tests	Skipped	Failures	Errors	Time
30	0 💤	0 ❌	0 🔥	0.237s ⏱️

[github-actions]

Coverage Report

File	Stmts	Miss	Cover	Missing
common
compression.py	5	1	80%	9
log.py	9	0	100%
utils.py	28	0	100%
common/qconnector
rabbitmq_connector.py	45	13	71%	23–24, 37–49, 52–65
consumer
event_consumer.py	34	0	100%
pgoutput_parser
base.py	61	0	100%
delete.py	14	0	100%
insert.py	15	0	100%
relation.py	27	0	100%
update.py	19	0	100%
producer
event_producer.py	148	15	90%	118–122, 215–217, 223–224, 245, 248–252
TOTAL	405	29	93%

Tests	Skipped	Failures	Errors	Time
30	0 💤	0 ❌	0 🔥	0.268s ⏱️