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: 6824   Key: connector-MongoDbSourceConnectorConnector-snapshot-v1   Timestamp: 2026-02-08 08:59:45.553 Headers: empty
 
empty
Partition: 0   Offset: 6825   Key: target-state-MongoDbSourceConnectorConnector-snapshot-v1   Timestamp: 2026-02-08 08:59:45.553 Headers: empty
 
empty
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: 6856   Key: connector-MongoDbSourceConnectorConnector-snapshot-v1.1   Timestamp: 2026-02-09 06:54:46.607 Headers: empty
 
empty
Partition: 0   Offset: 6857   Key: target-state-MongoDbSourceConnectorConnector-snapshot-v1.1   Timestamp: 2026-02-09 06:54:46.607 Headers: empty
 
empty
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: 6865   Key: connector-MongoDbSourceConnectorConnector-snapshot-v1.2.1   Timestamp: 2026-02-09 07:58:09.758 Headers: empty
 
empty
Partition: 0   Offset: 6866   Key: target-state-MongoDbSourceConnectorConnector-snapshot-v1.2.1   Timestamp: 2026-02-09 07:58:09.759 Headers: empty
 
empty
Partition: 0   Offset: 6868   Key: connector-MongoDbSourceConnectorConnector-snapshot-vr1.2.1   Timestamp: 2026-02-09 09:10:52.681 Headers: empty
 
empty
Partition: 0   Offset: 6869   Key: target-state-MongoDbSourceConnectorConnector-snapshot-vr1.2.1   Timestamp: 2026-02-09 09:10:52.681 Headers: empty
 
empty
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: 6897   Key: connector-MongoDbSourceConnectorConnector-snapshot-vr1.1.2   Timestamp: 2026-02-10 08:57:55.845 Headers: empty
 
empty
Partition: 0   Offset: 6898   Key: target-state-MongoDbSourceConnectorConnector-snapshot-vr1.1.2   Timestamp: 2026-02-10 08:57:55.845 Headers: empty
 
empty
Partition: 0   Offset: 6900   Key: connector-MongoDbSourceConnectorConnector-snapshot-vv-rnd-1   Timestamp: 2026-02-10 09:32:31.811 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":"initial","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-snapshot-vv-rnd-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: 6905   Key: session-key   Timestamp: 2026-02-10 12:21:46.884 Headers: empty
 
{"key":"/FNzbLgiStkFryzmkj5N6jS7UrysP5YfV4tSVKlVqWE=","algorithm":"HmacSHA256","creation-timestamp":1770726106883}
Partition: 0   Offset: 6906   Key: session-key   Timestamp: 2026-02-15 05:09:57.277 Headers: empty
 
{"key":"kJRmS5KBEzBJysLayLZ98W4FiY1QFEIGXxKLodBU7Pc=","algorithm":"HmacSHA256","creation-timestamp":1771132197277}
Partition: 0   Offset: 6907   Key: session-key   Timestamp: 2026-02-15 06:09:57.279 Headers: empty
 
{"key":"7c8Q6Y6S3GFXXyaXr/YlxoarmpYa0Dn4OiYzZZIdYBc=","algorithm":"HmacSHA256","creation-timestamp":1771135797277}
Partition: 0   Offset: 6908   Key: session-key   Timestamp: 2026-02-15 07:09:57.278 Headers: empty
 
{"key":"vyIi0151hjPSFag/4qm24UHU3YdRpAyAGajMJOxnR3A=","algorithm":"HmacSHA256","creation-timestamp":1771139397277}
Partition: 0   Offset: 6909   Key: session-key   Timestamp: 2026-02-15 08:09:57.278 Headers: empty
 
{"key":"yxZpZ4/J33qUHo+jRFdfEDUzK5rxOxYIASflQZqEdJ4=","algorithm":"HmacSHA256","creation-timestamp":1771142997277}
Partition: 0   Offset: 6910   Key: session-key   Timestamp: 2026-02-15 09:09:57.279 Headers: empty
 
{"key":"KHp7aApADG2mDI65Yq0lmOcrx5URdYKhueh3eki8f3Y=","algorithm":"HmacSHA256","creation-timestamp":1771146597278}
Partition: 0   Offset: 6911   Key: session-key   Timestamp: 2026-02-15 10:09:57.279 Headers: empty
 
{"key":"705IpPZP51s1k8k5l8UuRRImxXp7A28sz899m1bCQng=","algorithm":"HmacSHA256","creation-timestamp":1771150197278}
Partition: 0   Offset: 6912   Key: session-key   Timestamp: 2026-02-15 11:09:57.280 Headers: empty
 
{"key":"1Z0DnaCSei9MdY7LHdm7H//2Q7Se6XeJ3YgluwazhKk=","algorithm":"HmacSHA256","creation-timestamp":1771153797279}
Partition: 0   Offset: 6913   Key: session-key   Timestamp: 2026-02-15 12:09:57.281 Headers: empty
 
{"key":"M5f4Llfva2CzyzN3gcgVTWU2VSdyK/dYz4NgGV/h38A=","algorithm":"HmacSHA256","creation-timestamp":1771157397279}
Partition: 0   Offset: 6914   Key: session-key   Timestamp: 2026-02-15 13:09:57.281 Headers: empty
 
{"key":"pQxRpCTBBqmUk+HP7Fhz1QMEgowiOa4WsC9wb0sr4VY=","algorithm":"HmacSHA256","creation-timestamp":1771160997280}
Partition: 0   Offset: 6915   Key: session-key   Timestamp: 2026-02-15 14:09:57.282 Headers: empty
 
{"key":"d45Z9Cu6sGc9uwRMWU5LF48txpMJQvp+lHlfwV3IgJw=","algorithm":"HmacSHA256","creation-timestamp":1771164597280}
Partition: 0   Offset: 6916   Key: session-key   Timestamp: 2026-02-15 15:09:57.281 Headers: empty
 
{"key":"e/ukqc/+MuZUMvyPfiOtP6dFebE2ZRRdRep/7VSxwtA=","algorithm":"HmacSHA256","creation-timestamp":1771168197280}
Partition: 0   Offset: 6917   Key: session-key   Timestamp: 2026-02-15 16:09:57.282 Headers: empty
 
{"key":"p/fir+zLrl3IMfy4zI1eO8EHwErhySm7TGMSfvdVcJM=","algorithm":"HmacSHA256","creation-timestamp":1771171797280}
Partition: 0   Offset: 6918   Key: session-key   Timestamp: 2026-02-15 17:09:57.281 Headers: empty
 
{"key":"WGlxoo6X/yjcj8ccQr0nXaVatvtjqcJRGOGWuLPLzKE=","algorithm":"HmacSHA256","creation-timestamp":1771175397280}
Partition: 0   Offset: 6919   Key: session-key   Timestamp: 2026-02-15 18:09:57.281 Headers: empty
 
{"key":"UkGKQGuLXi1PJF9qgK6NAcuD/MyvtT1QZTn4oHmpRLo=","algorithm":"HmacSHA256","creation-timestamp":1771178997280}
Partition: 0   Offset: 6920   Key: session-key   Timestamp: 2026-02-15 19:09:57.281 Headers: empty
 
{"key":"MeNdP3aJeYmzYQ/SctnjEaj6jBH/S4f82sOoBFNZDJ4=","algorithm":"HmacSHA256","creation-timestamp":1771182597280}
Partition: 0   Offset: 6921   Key: session-key   Timestamp: 2026-02-15 20:09:57.281 Headers: empty
 
{"key":"DNzSTeqFbVOLeiAbHIymPsmStDpSP6kvWUqRvvXpXNY=","algorithm":"HmacSHA256","creation-timestamp":1771186197280}