Skip to content

Instantly share code, notes, and snippets.

@anand086

anand086/msk_connector_cloudwatch_eu-central-1

Created September 4, 2022 08:23
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save anand086/e1d9abdc61bcd6644f62234ddfa29732 to your computer and use it in GitHub Desktop.
Save anand086/e1d9abdc61bcd6644f62234ddfa29732 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
msk_connector_cloudwatch_eu-central-1
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:54,563] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] WorkerSinkTask{id=lensesio-msk-transaction-events-src-s3-1-0} Committing offsets asynchronously using sequence number 11: {transaction_events-0=OffsetAndMetadata{offset=8, leaderEpoch=null, metadata=''}, transaction_events-1=OffsetAndMetadata{offset=3, leaderEpoch=null, metadata=''}, transaction_events-2=OffsetAndMetadata{offset=9, leaderEpoch=null, metadata=''}, transaction_events-3=OffsetAndMetadata{offset=107, leaderEpoch=null, metadata=''}, transaction_events-4=OffsetAndMetadata{offset=8, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:352)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:54,733] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] WorkerSinkTask{id=lensesio-msk-transaction-events-src-s3-1-1} Committing offsets asynchronously using sequence number 11: {transaction_events-8=OffsetAndMetadata{offset=105, leaderEpoch=null, metadata=''}, transaction_events-9=OffsetAndMetadata{offset=95, leaderEpoch=null, metadata=''}, transaction_events-5=OffsetAndMetadata{offset=98, leaderEpoch=null, metadata=''}, transaction_events-6=OffsetAndMetadata{offset=102, leaderEpoch=null, metadata=''}, transaction_events-7=OffsetAndMetadata{offset=107, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:352)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:55,050] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:55,250] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:56,056] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:56,462] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:56,660] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:57,063] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:57,264] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:57,671] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:12:59,480] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:13:02,917] INFO [lensesio-msk-transaction-events-src-s3-1|task-1] JsonConverterConfig values:
[Worker-064f2e13cca81bb69] converter.type = value
[Worker-064f2e13cca81bb69] decimal.format = BASE64
[Worker-064f2e13cca81bb69] schemas.cache.size = 1000
[Worker-064f2e13cca81bb69] schemas.enable = false
[Worker-064f2e13cca81bb69] (org.apache.kafka.connect.json.JsonConverterConfig:361)
[Worker-064f2e13cca81bb69] [2022-09-04 08:13:54,563] INFO [lensesio-msk-transaction-events-src-s3-1|task-0] WorkerSinkTask{id=lensesio-msk-transaction-events-src-s3-1-0} Committing offsets asynchronously using sequence number 12: {transaction_events-0=OffsetAndMetadata{offset=133, leaderEpoch=null, metadata=''}, transaction_events-1=OffsetAndMetadata{offset=112, leaderEpoch=null, metadata=''}, transaction_events-2=OffsetAndMetadata{offset=113, leaderEpoch=null, metadata=''}, transaction_events-3=OffsetAndMetadata{offset=107, leaderEpoch=null, metadata=''}, transaction_events-4=OffsetAndMetadata{offset=95, leaderEpoch=null, metadata=''}} (org.apache.kafka.connect.runtime.WorkerSinkTask:352)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment