{
	"name": "docdb-connector",
	"connector": {
		"state": "RUNNING",
		"worker_id": "10.30.26.11:8083"
	},
	"tasks": [{
		"id": 0,
		"state": "FAILED",
		"worker_id": "10.30.26.11:8083",
		"trace": "
	  org.apache.kafka.connect.errors.ConnectException: 
	  An exception occurred in the change event producer. This connector will be stopped.
	  io.debezium.pipeline.ErrorHandler.setProducerThrowable(ErrorHandler.java:50)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:122)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:96)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.execute(MongoDbStreamingChangeEventSource.java:52)
	  io.debezium.pipeline.ChangeEventSourceCoordinator.streamEvents(ChangeEventSourceCoordinator.java:174)
	  io.debezium.pipeline.ChangeEventSourceCoordinator.executeChangeEventSources(ChangeEventSourceCoordinator.java:141)
	  io.debezium.pipeline.ChangeEventSourceCoordinator.lambda$start$0(ChangeEventSourceCoordinator.java:109)
	  java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
	  java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
	  java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
	  java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
	  java.base/java.lang.Thread.run(Thread.java:833)
	  Caused by: org.apache.kafka.connect.errors.ConnectException: Error while attempting to read from change stream on 'rs0/****.ap-northeast-2.docdb.amazonaws.com:27017'
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$establishConnectionToPrimary$3(MongoDbStreamingChangeEventSource.java:165)
	  io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:286)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.streamChangesForReplicaSet(MongoDbStreamingChangeEventSource.java:115)
	  ...10 more
	  Caused by: com.mongodb.MongoCommandException: Command failed with error 136: 
	  'CappedPositionLost: CollectionScan died due to position in capped collection being deleted.' on server ****.ap-northeast-2.docdb.amazonaws.com:27017.
  	  The full response is {\"ok\": 0.0, \"operationTime\": {\"$timestamp\": {\"t\": 1657179834, \"i\": 1}}, \"code\": 136, \"errmsg\": \"CappedPositionLost: CollectionScan died due to position in capped collection being deleted.\"}
	  com.mongodb.internal.connection.ProtocolHelper.getCommandFailureException(ProtocolHelper.java:198)
	  com.mongodb.internal.connection.InternalStreamConnection.receiveCommandMessageResponse(InternalStreamConnection.java:413)
	  com.mongodb.internal.connection.InternalStreamConnection.sendAndReceive(InternalStreamConnection.java:337)
	  com.mongodb.internal.connection.UsageTrackingInternalConnection.sendAndReceive(UsageTrackingInternalConnection.java:116)
	  com.mongodb.internal.connection.DefaultConnectionPool$PooledConnection.sendAndReceive(DefaultConnectionPool.java:644)
	  com.mongodb.internal.connection.CommandProtocolImpl.execute(CommandProtocolImpl.java:71)
	  com.mongodb.internal.connection.DefaultServer$DefaultServerProtocolExecutor.execute(DefaultServer.java:240)
	  com.mongodb.internal.connection.DefaultServerConnection.executeProtocol(DefaultServerConnection.java:226)
	  com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:126)
	  com.mongodb.internal.connection.DefaultServerConnection.command(DefaultServerConnection.java:116)
	  com.mongodb.internal.connection.DefaultServer$OperationCountTrackingConnection.command(DefaultServer.java:345)
	  com.mongodb.internal.operation.CommandOperationHelper.createReadCommandAndExecute(CommandOperationHelper.java:232)
	  com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$4(CommandOperationHelper.java:214)
	  com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$2(OperationHelper.java:575)
	  com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:600)
	  com.mongodb.internal.operation.OperationHelper.lambda$withSourceAndConnection$3(OperationHelper.java:574)
	  com.mongodb.internal.operation.OperationHelper.withSuppliedResource(OperationHelper.java:600)
	  com.mongodb.internal.operation.OperationHelper.withSourceAndConnection(OperationHelper.java:573)
	  com.mongodb.internal.operation.CommandOperationHelper.lambda$executeRetryableRead$5(CommandOperationHelper.java:211)
	  com.mongodb.internal.async.function.RetryingSyncSupplier.get(RetryingSyncSupplier.java:65)
	  com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:217)
	  com.mongodb.internal.operation.CommandOperationHelper.executeRetryableRead(CommandOperationHelper.java:197)
	  com.mongodb.internal.operation.AggregateOperationImpl.execute(AggregateOperationImpl.java:195)
	  com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:347)
	  com.mongodb.internal.operation.ChangeStreamOperation$1.call(ChangeStreamOperation.java:343)
	  com.mongodb.internal.operation.OperationHelper.withReadConnectionSource(OperationHelper.java:538)
	  com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:343)
	  com.mongodb.internal.operation.ChangeStreamOperation.execute(ChangeStreamOperation.java:58)
	  com.mongodb.client.internal.MongoClientDelegate$DelegateOperationExecutor.execute(MongoClientDelegate.java:191)
	  com.mongodb.client.internal.ChangeStreamIterableImpl.execute(ChangeStreamIterableImpl.java:221)
	  com.mongodb.client.internal.ChangeStreamIterableImpl.cursor(ChangeStreamIterableImpl.java:174)
	  com.mongodb.client.internal.ChangeStreamIterableImpl.iterator(ChangeStreamIterableImpl.java:169)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.readChangeStream(MongoDbStreamingChangeEventSource.java:233)
	  io.debezium.connector.mongodb.MongoDbStreamingChangeEventSource.lambda$streamChangesForReplicaSet$0(MongoDbStreamingChangeEventSource.java:116)
	  io.debezium.connector.mongodb.ConnectionContext$MongoPrimary.execute(ConnectionContext.java:282)
	  ... 11 more"
	}],
	"type": "source"
}