Topic Messages: connect-configs

Partition: 0   Offset: 4983   Key: task-npf-elasticsearch-sink-0   Timestamp: 2025-11-30 13:06:36.883 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"false","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.migration_v2\\.(.*)","write.method":"UPSERT","elastic.https.ssl.truststore.password":"TheNPFPAss","transforms.route.replacement":"npf_search_index","elastic.https.ssl.truststore.type":"JKS","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.migration_v2\\..*","schema.ignore":"true","flush.synchronously":"true","elastic.https.ssl.protocol":"TLS","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","elastic.security.protocol":"SSL","name":"npf-elasticsearch-sink","connection.url":"https://10.12.2.87:9200","elastic.https.ssl.truststore.location":"/opt/automq/connect-certs/elastic-truststore.jks","taskId":"0"}}
Partition: 0   Offset: 4984   Key: commit-npf-elasticsearch-sink   Timestamp: 2025-11-30 13:06:36.887 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5016   Key: task-MongoDbSourceConnectorConnector-0   Timestamp: 2025-12-01 11:28:02.887 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded\\.dyn_.*","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5017   Key: commit-MongoDbSourceConnectorConnector   Timestamp: 2025-12-01 11:28:02.890 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5021   Key: task-MongoDbSourceConnectorConnector-test-0   Timestamp: 2025-12-01 11:43:05.416 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded\\.dyn_.*","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5022   Key: commit-MongoDbSourceConnectorConnector-test   Timestamp: 2025-12-01 11:43:05.919 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5026   Key: task-MongoDbSourceConnectorConnector-test-1-0   Timestamp: 2025-12-01 11:59:39.180 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_cabinet_photo_galleries,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,row_status,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5027   Key: commit-MongoDbSourceConnectorConnector-test-1   Timestamp: 2025-12-01 11:59:39.184 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5031   Key: task-npf-elasticsearch-sink-v2-0   Timestamp: 2025-12-01 12:07:51.842 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"false","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.npf_admin_sharded\\.(.*)","write.method":"UPSERT","elastic.https.ssl.truststore.password":"TheNPFPAss","transforms.route.replacement":"npf_search_index","elastic.https.ssl.truststore.type":"JKS","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.npf_admin_sharded\\..*","schema.ignore":"true","flush.synchronously":"true","elastic.https.ssl.protocol":"TLS","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","elastic.security.protocol":"SSL","name":"npf-elasticsearch-sink-v2","connection.url":"https://10.12.2.87:9200","elastic.https.ssl.truststore.location":"/opt/automq/connect-certs/elastic-truststore.jks","taskId":"0"}}
Partition: 0   Offset: 5032   Key: commit-npf-elasticsearch-sink-v2   Timestamp: 2025-12-01 12:07:51.845 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5036   Key: task-npf-elasticsearch-sink-v2.1-0   Timestamp: 2025-12-01 12:20:27.487 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"false","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.npf_admin_sharded\\.(.*)","write.method":"UPSERT","elastic.https.ssl.truststore.password":"TheNPFPAss","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.route.replacement":"npf_search_index","key.converter":"org.apache.kafka.connect.json.JsonConverter","elastic.https.ssl.truststore.type":"JKS","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.npf_admin_sharded\\..*","schema.ignore":"true","flush.synchronously":"true","key.converter.schemas.enable":"false","elastic.https.ssl.protocol":"TLS","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","elastic.security.protocol":"SSL","value.converter.schemas.enable":"false","name":"npf-elasticsearch-sink-v2.1","connection.url":"https://10.12.2.87:9200","elastic.https.ssl.truststore.location":"/opt/automq/connect-certs/elastic-truststore.jks","taskId":"0"}}
Partition: 0   Offset: 5037   Key: commit-npf-elasticsearch-sink-v2.1   Timestamp: 2025-12-01 12:20:27.490 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5042   Key: task-npf-elasticsearch-sink-v2.2-0   Timestamp: 2025-12-01 13:04:14.705 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"false","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.npf_admin_sharded\\.(.*)","write.method":"UPSERT","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.route.replacement":"npf_search_index","key.converter":"org.apache.kafka.connect.json.JsonConverter","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.npf_admin_sharded\\..*","schema.ignore":"true","flush.synchronously":"true","key.converter.schemas.enable":"false","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","value.converter.schemas.enable":"false","name":"npf-elasticsearch-sink-v2.2","connection.url":"http://10.12.2.87:9201","taskId":"0"}}
Partition: 0   Offset: 5043   Key: commit-npf-elasticsearch-sink-v2.2   Timestamp: 2025-12-01 13:04:14.709 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5047   Key: task-npf-elasticsearch-sink-v2.3-0   Timestamp: 2025-12-01 13:19:58.855 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"true","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.npf_admin_sharded\\.(.*)","write.method":"UPSERT","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.route.replacement":"npf_search_index","key.converter":"org.apache.kafka.connect.json.JsonConverter","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.npf_admin_sharded\\..*","schema.ignore":"true","flush.synchronously":"true","key.converter.schemas.enable":"false","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","value.converter.schemas.enable":"false","name":"npf-elasticsearch-sink-v2.3","connection.url":"http://10.12.2.87:9201","taskId":"0"}}
Partition: 0   Offset: 5048   Key: commit-npf-elasticsearch-sink-v2.3   Timestamp: 2025-12-01 13:19:58.858 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5053   Key: task-npf-elasticsearch-sink-v2.4-0   Timestamp: 2025-12-01 13:53:36.274 Headers: empty
 
{"properties":{"connector.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkConnector","behavior.on.null.values":"DELETE","connection.password":"q1w2e3r4","transforms":"route","max.retries":"10","key.ignore":"true","retry.backoff.ms":"2000","transforms.route.type":"org.apache.kafka.connect.transforms.RegexRouter","transforms.route.regex":"mongodb\\.npf_admin_sharded\\.(.*)","write.method":"UPSERT","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.route.replacement":"npf_search_index","key.converter":"org.apache.kafka.connect.json.JsonConverter","batch.size":"2000","connection.username":"elastic","max.in.flight.requests":"2","topics.regex":"mongodb\\.npf_admin_sharded\\..*","schema.ignore":"true","flush.synchronously":"true","key.converter.schemas.enable":"false","flush.timeout.ms":"180000","task.class":"io.confluent.connect.elasticsearch.ElasticsearchSinkTask","value.converter.schemas.enable":"false","name":"npf-elasticsearch-sink-v2.4","connection.url":"http://10.12.2.87:9201","taskId":"0"}}
Partition: 0   Offset: 5054   Key: commit-npf-elasticsearch-sink-v2.4   Timestamp: 2025-12-01 13:53:36.277 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5224   Key: task-MongoDbSourceConnectorConnector-test-2-0   Timestamp: 2025-12-08 09:39:00.618 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_cabinet_photo_galleries,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-2","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,row_status,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection,sort_order,publish_date,archive_date","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5225   Key: commit-MongoDbSourceConnectorConnector-test-2   Timestamp: 2025-12-08 09:39:00.623 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5229   Key: task-MongoDbSourceConnectorConnector-test-2.1-0   Timestamp: 2025-12-08 10:14:43.529 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_cabinet_photo_galleries,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-2.1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,row_status,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection,sort_order,publish_date,archive_date","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5230   Key: commit-MongoDbSourceConnectorConnector-test-2.1   Timestamp: 2025-12-08 10:14:43.532 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5236   Key: task-MongoDbSourceConnectorConnector-test-2.2-0   Timestamp: 2025-12-08 11:45:41.174 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_cabinet_photo_galleries,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-2.2","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,website_id,office_id,row_status,title_en,title_bn,description_en,description_bn,name_en,name_bn,designation_en,designation_bn,tags,language,published_at,url,collection,sort_order,publish_date,archive_date","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5237   Key: commit-MongoDbSourceConnectorConnector-test-2.2   Timestamp: 2025-12-08 11:45:41.177 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5266   Key: task-MongoDbSourceConnectorConnector-test-c1-0   Timestamp: 2025-12-09 12:42:03.182 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5267   Key: commit-MongoDbSourceConnectorConnector-test-c1   Timestamp: 2025-12-09 12:42:03.184 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5272   Key: task-MongoDbSourceConnectorConnector-test-c1.1-0   Timestamp: 2025-12-09 13:31:05.749 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"3","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5273   Key: commit-MongoDbSourceConnectorConnector-test-c1.1   Timestamp: 2025-12-09 13:31:05.753 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5295   Key: task-MongoDbSourceConnectorConnector-test-c1.2-0   Timestamp: 2025-12-10 07:49:41.910 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.2","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5296   Key: commit-MongoDbSourceConnectorConnector-test-c1.2   Timestamp: 2025-12-10 07:49:41.916 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5303   Key: task-MongoDbSourceConnectorConnector-test-c1.3-0   Timestamp: 2025-12-10 11:07:26.739 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.3","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5304   Key: commit-MongoDbSourceConnectorConnector-test-c1.3   Timestamp: 2025-12-10 11:07:26.744 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5309   Key: task-MongoDbSourceConnectorConnector-test-c1.4-0   Timestamp: 2025-12-10 11:54:45.136 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.4","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5310   Key: commit-MongoDbSourceConnectorConnector-test-c1.4   Timestamp: 2025-12-10 11:54:45.139 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5314   Key: task-MongoDbSourceConnectorConnector-test-c1.5-0   Timestamp: 2025-12-10 12:09:09.494 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.5","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5315   Key: commit-MongoDbSourceConnectorConnector-test-c1.5   Timestamp: 2025-12-10 12:09:09.497 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5319   Key: task-MongoDbSourceConnectorConnector-test-c1.6-0   Timestamp: 2025-12-10 12:17:16.106 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"6242880","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.6","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5320   Key: commit-MongoDbSourceConnectorConnector-test-c1.6   Timestamp: 2025-12-10 12:17:16.109 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5330   Key: task-MongoDbSourceConnectorConnector-test-c1.7-0   Timestamp: 2025-12-10 12:52:23.520 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.7","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5331   Key: commit-MongoDbSourceConnectorConnector-test-c1.7   Timestamp: 2025-12-10 12:52:23.523 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5335   Key: task-MongoDbSourceConnectorConnector-test-c1.8-0   Timestamp: 2025-12-10 13:06:50.694 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.8","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5336   Key: commit-MongoDbSourceConnectorConnector-test-c1.8   Timestamp: 2025-12-10 13:06:50.697 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5340   Key: task-MongoDbSourceConnectorConnector-test-c1.9-0   Timestamp: 2025-12-10 13:17:40.675 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"10485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.9","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5341   Key: commit-MongoDbSourceConnectorConnector-test-c1.9   Timestamp: 2025-12-10 13:17:40.679 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5366   Key: task-MongoDbSourceConnectorConnector-test-c1.10-0   Timestamp: 2025-12-11 09:54:08.057 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.10","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5367   Key: commit-MongoDbSourceConnectorConnector-test-c1.10   Timestamp: 2025-12-11 09:54:08.060 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5372   Key: task-MongoDbSourceConnectorConnector-test-c1.11-0   Timestamp: 2025-12-11 10:31:20.642 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_static_pages","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.11","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5373   Key: commit-MongoDbSourceConnectorConnector-test-c1.11   Timestamp: 2025-12-11 10:31:20.646 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5377   Key: task-MongoDbSourceConnectorConnector-test-c1.12-0   Timestamp: 2025-12-11 11:07:46.989 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.12","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5378   Key: commit-MongoDbSourceConnectorConnector-test-c1.12   Timestamp: 2025-12-11 11:07:46.994 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5383   Key: task-MongoDbSourceConnectorConnector-test-c1.13-0   Timestamp: 2025-12-11 11:38:12.844 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.13","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5384   Key: commit-MongoDbSourceConnectorConnector-test-c1.13   Timestamp: 2025-12-11 11:38:12.847 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5389   Key: task-MongoDbSourceConnectorConnector-test-c1.14-0   Timestamp: 2025-12-11 12:44:49.825 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.14","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5390   Key: commit-MongoDbSourceConnectorConnector-test-c1.14   Timestamp: 2025-12-11 12:44:49.829 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5395   Key: task-MongoDbSourceConnectorConnector-test-c1.15-0   Timestamp: 2025-12-11 13:25:19.625 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.15","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5396   Key: commit-MongoDbSourceConnectorConnector-test-c1.15   Timestamp: 2025-12-11 13:25:19.629 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5400   Key: task-MongoDbSourceConnectorConnector-test-c1.16-0   Timestamp: 2025-12-11 14:04:38.693 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"20485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-test-c1.16","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5401   Key: commit-MongoDbSourceConnectorConnector-test-c1.16   Timestamp: 2025-12-11 14:04:38.696 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5468   Key: task-MongoDbSourceConnectorConnector-prod-v3-0   Timestamp: 2025-12-14 04:55:54.782 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"50485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-prod-v3","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 5469   Key: commit-MongoDbSourceConnectorConnector-prod-v3   Timestamp: 2025-12-14 04:55:54.785 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 5673   Key: task-MongoDbSourceConnectorConnector-snapshot-v1-0   Timestamp: 2025-12-22 12:33:49.042 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"52428800","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"50485760","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-v1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 5674   Key: commit-MongoDbSourceConnectorConnector-snapshot-v1   Timestamp: 2025-12-22 12:33:49.044 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6854   Key: task-MongoDbSourceConnectorConnector-snapshot-v1.1-0   Timestamp: 2026-02-09 06:52:10.706 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-v1.1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 6855   Key: commit-MongoDbSourceConnectorConnector-snapshot-v1.1   Timestamp: 2026-02-09 06:52:10.710 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6859   Key: task-MongoDbSourceConnectorConnector-snapshot-v1.2.1-0   Timestamp: 2026-02-09 06:57:01.726 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-v1.2.1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 6860   Key: commit-MongoDbSourceConnectorConnector-snapshot-v1.2.1   Timestamp: 2026-02-09 06:57:01.730 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6863   Key: task-MongoDbSourceConnectorConnector-snapshot-vr1.2.1-0   Timestamp: 2026-02-09 07:57:07.182 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"fail","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-vr1.2.1","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 6864   Key: commit-MongoDbSourceConnectorConnector-snapshot-vr1.2.1   Timestamp: 2026-02-09 07:57:07.186 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6871   Key: task-MongoDbSourceConnectorConnector-snapshot-vr1.1.2-0   Timestamp: 2026-02-09 09:15:02.219 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.2.209:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"skip","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-vr1.1.2","errors.tolerance":"all","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 6872   Key: commit-MongoDbSourceConnectorConnector-snapshot-vr1.1.2   Timestamp: 2026-02-09 09:15:02.222 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6901   Key: task-MongoDbSourceConnectorConnector-snapshot-vv-rnd-1-0   Timestamp: 2026-02-10 09:32:31.844 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.3.40:27017,10.12.3.123:27017,10.12.3.162:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"skip","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-snapshot-vv-rnd-1","errors.tolerance":"all","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"initial"}}
Partition: 0   Offset: 6902   Key: commit-MongoDbSourceConnectorConnector-snapshot-vv-rnd-1   Timestamp: 2026-02-10 09:32:31.846 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 6961   Key: connector-MongoDbSourceConnectorConnector-single-prod-9375616389   Timestamp: 2026-02-17 10:02:40.365 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","mongodb.connection.mode":"sharded","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.3.40:27017,10.12.3.123:27017,10.12.3.162:27017/?authSource=admin","mongodb.members.auto.discover":"true","mongodb.user":"admin","mongodb.password":"npf-uetw-37rge-ered","mongodb.authsource":"admin","mongodb.ssl.enabled":"false","mongodb.ssl.invalid.hostname.allowed":"true","capture.scope":"database","capture.target":"npf_admin_sharded","filters.match.mode":"regex","database.include.list":"npf_admin_sharded","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","topic.prefix":"mongodb","topic.creation.default.partitions":"1","topic.creation.default.replication.factor":"1","tasks.max":"1","tasks.max.enforce":"false","max.queue.size":"500","max.batch.size":"100","max.queue.size.in.bytes":"209715200","producer.override.max.request.size":"209715200","schema.name.adjustment.mode":"none","event.processing.failure.handling.mode":"skip","errors.tolerance":"all","snapshot.mode":"never","value.converter":"org.apache.kafka.connect.json.JsonConverter","value.converter.schemas.enable":"false","transforms":"unwrap,rename,filter","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","transforms.unwrap.add.fields":"collection","transforms.unwrap.add.fields.prefix":"__","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.rename.renames":"_id:mongo_id,__collection:collection","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","name":"MongoDbSourceConnectorConnector-single-prod-9375616389"}}
Partition: 0   Offset: 6962   Key: task-MongoDbSourceConnectorConnector-single-prod-9375616389-0   Timestamp: 2026-02-17 10:02:40.390 Headers: empty
 
{"properties":{"connector.class":"io.debezium.connector.mongodb.MongoDbConnector","collection.include.list":"npf_admin_sharded.dyn_notices,npf_admin_sharded.dyn_news,npf_admin_sharded.dyn_static_pages,npf_admin_sharded.dyn_publications,npf_admin_sharded.dyn_jobs,npf_admin_sharded.dyn_event_calendars,npf_admin_sharded.dyn_office_process_maps,npf_admin_sharded.dyn_sps_datas,npf_admin_sharded.dyn_office_heads,npf_admin_sharded.dyn_biographies,npf_admin_sharded.dyn_press_releases,npf_admin_sharded.dyn_tenders,npf_admin_sharded.dyn_office_orders,npf_admin_sharded.dyn_projects,npf_admin_sharded.dyn_policies,npf_admin_sharded.dyn_annual_reports,npf_admin_sharded.dyn_photo_galleries,npf_admin_sharded.dyn_files,npf_admin_sharded.dyn_forms,npf_admin_sharded.dyn_innovation_corners,npf_admin_sharded.dyn_common_documents,npf_admin_sharded.dyn_miscellaneous_infos,npf_admin_sharded.dyn_downloads,npf_admin_sharded.dyn_go_ultimates,npf_admin_sharded.dyn_moedu_office_orders,npf_admin_sharded.dyn_mopa_go_ultimate,npf_admin_sharded.dyn_video_galleries,npf_admin_sharded.dyn_officers,npf_admin_sharded.dyn_staff_profiles,npf_admin_sharded.dyn_cabinet_secretaries,npf_admin_sharded.dyn_mopa_go","max.queue.size":"500","mongodb.connection.mode":"sharded","topic.creation.default.partitions":"1","mongodb.connection.string":"mongodb://admin:npf-uetw-37rge-ered@10.12.3.40:27017,10.12.3.123:27017,10.12.3.162:27017/?authSource=admin","mongodb.password":"npf-uetw-37rge-ered","tasks.max":"1","filters.match.mode":"regex","transforms":"unwrap,rename,filter","transforms.rename.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","mongodb.ssl.enabled":"false","topic.prefix":"mongodb","mongodb.members.auto.discover":"true","mongodb.authsource":"admin","capture.scope":"database","topic.creation.default.replication.factor":"1","transforms.unwrap.type":"io.debezium.connector.mongodb.transforms.ExtractNewDocumentState","tasks.max.enforce":"false","value.converter":"org.apache.kafka.connect.json.JsonConverter","transforms.rename.renames":"_id:mongo_id,__collection:collection","max.queue.size.in.bytes":"209715200","mongodb.user":"admin","event.processing.failure.handling.mode":"skip","transforms.filter.type":"org.apache.kafka.connect.transforms.ReplaceField$Value","producer.override.max.request.size":"209715200","transforms.unwrap.add.fields.prefix":"__","task.class":"io.debezium.connector.mongodb.MongoDbConnectorTask","schema.name.adjustment.mode":"none","capture.target":"npf_admin_sharded","value.converter.schemas.enable":"false","name":"MongoDbSourceConnectorConnector-single-prod-9375616389","errors.tolerance":"all","transforms.unwrap.add.fields":"collection","mongodb.ssl.invalid.hostname.allowed":"true","transforms.filter.whitelist":"mongo_id,cluster_id,website_id,office_id,sort_order,row_status,title_en,title_bn,description_en,description_bn,org_name_en,org_name_bn,name_en,name_bn,designation_en,designation_bn,publish_date,archive_date,updatedAt,tags,language,published_at,url,collection,office_div_branch_name_bn,tender_type,branch,photo_gallery_type,video_gallery_type,form_cat,forms_portal_cat,innovation_corner_type,miscellaneous_info_type,order,category,order_type,doctype,officer_category,division,bcs_batch,designation_id,go_type,wing,section","max.batch.size":"100","database.include.list":"npf_admin_sharded","snapshot.mode":"never"}}
Partition: 0   Offset: 6963   Key: commit-MongoDbSourceConnectorConnector-single-prod-9375616389   Timestamp: 2026-02-17 10:02:40.393 Headers: empty
 
{"tasks":1}
Partition: 0   Offset: 8086   Key: session-key   Timestamp: 2026-04-05 04:09:57.588 Headers: empty
 
{"key":"iMMahW35btTnC4y4a7UiVJ6J+ri4xSsKbQ0Q/wNmLDo=","algorithm":"HmacSHA256","creation-timestamp":1775362197587}
Partition: 0   Offset: 8087   Key: session-key   Timestamp: 2026-04-05 05:09:57.588 Headers: empty
 
{"key":"/fpwK69/Fh1jJ2etjyZj5L9fw1kd9M/VwcZR6MpbLjE=","algorithm":"HmacSHA256","creation-timestamp":1775365797587}
Partition: 0   Offset: 8088   Key: session-key   Timestamp: 2026-04-05 06:09:57.588 Headers: empty
 
{"key":"TDgkmQUJwkESwXv6hbgejapGi1kiOg5gx/JsGN1vxhk=","algorithm":"HmacSHA256","creation-timestamp":1775369397587}
Partition: 0   Offset: 8089   Key: session-key   Timestamp: 2026-04-05 07:09:57.588 Headers: empty
 
{"key":"8OinSPNvEcpz4njEHMYc/0jP2J96J/dRqwArhStPyQA=","algorithm":"HmacSHA256","creation-timestamp":1775372997587}
Partition: 0   Offset: 8090   Key: session-key   Timestamp: 2026-04-05 08:09:57.588 Headers: empty
 
{"key":"qwuhU3gFGfPvt8KOUZCHQooj8486h4LHlATn4H+wnZQ=","algorithm":"HmacSHA256","creation-timestamp":1775376597587}
Partition: 0   Offset: 8091   Key: session-key   Timestamp: 2026-04-05 09:09:57.588 Headers: empty
 
{"key":"Wf4i67WpY2HIkdlehurf+Fm4bYw/3k7YxjBWKqAOJAA=","algorithm":"HmacSHA256","creation-timestamp":1775380197587}
Partition: 0   Offset: 8092   Key: session-key   Timestamp: 2026-04-05 10:09:57.588 Headers: empty
 
{"key":"V1q3hm1lknTfQzFKM8JkJeVQ4mbNFLyJZB44JIRwMck=","algorithm":"HmacSHA256","creation-timestamp":1775383797588}
Partition: 0   Offset: 8093   Key: session-key   Timestamp: 2026-04-05 11:09:57.589 Headers: empty
 
{"key":"qESLqY/Hcl8K60Ppes7VSFNYkd48sUYmepL/b4SaWZY=","algorithm":"HmacSHA256","creation-timestamp":1775387397588}
Partition: 0   Offset: 8094   Key: session-key   Timestamp: 2026-04-05 12:09:57.589 Headers: empty
 
{"key":"SXgFrwzoTO5DhcLOcrPjOXDzHoILtOn684+rdsiLA6A=","algorithm":"HmacSHA256","creation-timestamp":1775390997588}
Partition: 0   Offset: 8095   Key: session-key   Timestamp: 2026-04-05 13:09:57.589 Headers: empty
 
{"key":"SxCod2DA88Act4G+mWi+p3fAmj/IM6sdHRiZ8scmCvE=","algorithm":"HmacSHA256","creation-timestamp":1775394597588}
Partition: 0   Offset: 8096   Key: session-key   Timestamp: 2026-04-05 14:09:57.589 Headers: empty
 
{"key":"Kc1TWJi+03bcI1tST0QcCrXkybxGeWIN7Mdjju7hMVo=","algorithm":"HmacSHA256","creation-timestamp":1775398197588}
Partition: 0   Offset: 8097   Key: session-key   Timestamp: 2026-04-05 15:09:57.589 Headers: empty
 
{"key":"QnwwE+AN7UTTPQaFF3B+Nts6pU3sn69+7zZgN/vEegc=","algorithm":"HmacSHA256","creation-timestamp":1775401797588}
Partition: 0   Offset: 8098   Key: session-key   Timestamp: 2026-04-05 16:09:57.589 Headers: empty
 
{"key":"f10hMRDZEmcSMx1tbfUHAiKPJtuWDbVeLxCRXF6UHXU=","algorithm":"HmacSHA256","creation-timestamp":1775405397588}
Partition: 0   Offset: 8099   Key: session-key   Timestamp: 2026-04-05 17:09:57.589 Headers: empty
 
{"key":"70jF9mzxzZJCIVIE0gH07UMiUjq9newNrH/nka03QFY=","algorithm":"HmacSHA256","creation-timestamp":1775408997588}
Partition: 0   Offset: 8100   Key: session-key   Timestamp: 2026-04-05 18:09:57.589 Headers: empty
 
{"key":"QQhPNbxFgEoDTmdhO9895LbeAo5fdNHz98HZpKyeMjo=","algorithm":"HmacSHA256","creation-timestamp":1775412597588}
Partition: 0   Offset: 8101   Key: session-key   Timestamp: 2026-04-05 19:09:57.589 Headers: empty
 
{"key":"6jctr0RsIa+DDe3Uas0HnB7Enfsrv/KkpEUgzfP1mKg=","algorithm":"HmacSHA256","creation-timestamp":1775416197589}
Partition: 0   Offset: 8102   Key: session-key   Timestamp: 2026-04-05 20:09:57.590 Headers: empty
 
{"key":"kdAryDQYrTIcL20PHwudX1/6yRm8/ZYMO/IGLiDB3T4=","algorithm":"HmacSHA256","creation-timestamp":1775419797589}
Partition: 0   Offset: 8103   Key: session-key   Timestamp: 2026-04-05 21:09:57.590 Headers: empty
 
{"key":"IvMoJ67TZkOtXbM5tYskG6lW06PtJSXWT/wfjXLbhFs=","algorithm":"HmacSHA256","creation-timestamp":1775423397589}
Partition: 0   Offset: 8104   Key: session-key   Timestamp: 2026-04-05 22:09:57.590 Headers: empty
 
{"key":"uj1Lnz1UbRMPB3deD808X3F764KknFlGvk//urTM5qE=","algorithm":"HmacSHA256","creation-timestamp":1775426997589}
Partition: 0   Offset: 8105   Key: session-key   Timestamp: 2026-04-05 23:09:57.590 Headers: empty
 
{"key":"/de6ePRXHjFgeUYS5GaBCiCtbs3k+PK4Q38u4/4/CV8=","algorithm":"HmacSHA256","creation-timestamp":1775430597589}
Partition: 0   Offset: 8106   Key: session-key   Timestamp: 2026-04-06 00:09:57.590 Headers: empty
 
{"key":"hICj5fzZ5QfxJNNCb4UK7O+cK8GmVMsE+5b/UcgKqlM=","algorithm":"HmacSHA256","creation-timestamp":1775434197589}
Partition: 0   Offset: 8107   Key: session-key   Timestamp: 2026-04-06 01:09:57.590 Headers: empty
 
{"key":"d1rWP+QUVaTvycx0TRSBKRGA90enJ1HDGGrrSNvKvsU=","algorithm":"HmacSHA256","creation-timestamp":1775437797589}
Partition: 0   Offset: 8108   Key: session-key   Timestamp: 2026-04-06 02:09:57.590 Headers: empty
 
{"key":"V461Dy1ka+RdDwfkhmPinhxnqyumU4Qyebh/ggqYgf0=","algorithm":"HmacSHA256","creation-timestamp":1775441397589}
Partition: 0   Offset: 8109   Key: session-key   Timestamp: 2026-04-06 03:09:57.590 Headers: empty
 
{"key":"NyWdh7a8CsR6Ct4KtE5V0vc1tZXQagLA0kB1KCPum+0=","algorithm":"HmacSHA256","creation-timestamp":1775444997589}
Partition: 0   Offset: 8110   Key: session-key   Timestamp: 2026-04-06 04:09:57.590 Headers: empty
 
{"key":"smfsnFZh/PZdZJL54AMOXCL/Pavmz5B3PdROfygY3lE=","algorithm":"HmacSHA256","creation-timestamp":1775448597589}