Code

Place offset manager in commons#373

Code

Open

Claudenw wants to merge 51 commits intoAiven-Open:s3-source-releaseAiven-Open/cloud-storage-connectors-for-apache-kafka:s3-source-releasefrom Claudenw:KCON-57_place_OffsetManager_in_commonsClaudenw/cloud-storage-connectors-for-apache-kafka:KCON-57_place_OffsetManager_in_commonsCopy head branch name to clipboard

+1,297-733

Commits

Commits on Dec 27, 2024

• intial changes

  

  ¨Claude

  committed
  29b360d

  Copy full SHA for 29b360d

• Merge remote-tracking branch 'origin/s3-source-release' into polling

  

  ¨Claude

  committed
  22fa3a0

  Copy full SHA for 22fa3a0

• fixed test cases

  

  ¨Claude

  committed
  b6f2d08

  Copy full SHA for b6f2d08

• Merge branch 's3-source-release' into polling_efficiency

  

  ¨Claude

  committed
  38fe822

  Copy full SHA for 38fe822

Commits on Dec 30, 2024

• Added more complete tests

  

  ¨Claude

  committed
  0a10606

  Copy full SHA for 0a10606

Commits on Dec 31, 2024

• Merge branch 's3-source-release' into polling_efficiency

  Claudenw

  authored
  d7b8236

  Copy full SHA for d7b8236

• Migrate to new AWS client

  

  ¨Claude

  committed
  9ccb1a8

  Copy full SHA for 9ccb1a8

• added AWS Integration test

  

  ¨Claude

  committed
  d3ce578

  Copy full SHA for d3ce578

Commits on Jan 2, 2025

• attempts to fix polling

  

  ¨Claude

  committed
  e744e32

  Copy full SHA for e744e32

• sped up integration test

  

  ¨Claude

  committed
  df11418

  Copy full SHA for df11418

Commits on Jan 6, 2025

• fixed tests

  

  ¨Claude

  committed
  be775b0

  Copy full SHA for be775b0

• removed unused class

  

  ¨Claude

  committed
  ebf0e8a

  Copy full SHA for ebf0e8a

• removed unused methods

  

  ¨Claude

  committed
  9c73cd4

  Copy full SHA for 9c73cd4

• Changes to allow Backoff to abort the timer

  

  ¨Claude

  committed
  d7b2f3c

  Copy full SHA for d7b2f3c

• updated javadoc

  

  ¨Claude

  committed
  cf32e79

  Copy full SHA for cf32e79

• Merge remote-tracking branch 'origin/s3-source-release' into polling_efficiency

  

  ¨Claude

  committed
  a7c2570

  Copy full SHA for a7c2570

• fixed PMD errors

  

  ¨Claude

  committed
  4dd9ad8

  Copy full SHA for 4dd9ad8

• fixed testing errors

  

  ¨Claude

  committed
  f401478

  Copy full SHA for f401478

• added javadoc

  

  ¨Claude

  committed
  1d73e7f

  Copy full SHA for 1d73e7f

Commits on Jan 7, 2025

• fixed backoff test issue

  

  ¨Claude

  committed
  2c0426a

  Copy full SHA for 2c0426a

• fixed testPollWithSlowProducer test issue

  

  ¨Claude

  committed
  332c3f5

  Copy full SHA for 332c3f5

• added test for AWSV2SourceClient rehydration

  

  ¨Claude

  committed
  06a12a3

  Copy full SHA for 06a12a3

• Fix for slow polling test

  

  ¨Claude

  committed
  0edf114

  Copy full SHA for 0edf114

• Changes as per review

  

  ¨Claude

  committed
  da17e1f

  Copy full SHA for da17e1f

Commits on Jan 9, 2025

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/AbstractSourceTask.java

  Show description for dc35ee4
  

  Claudenw

  and

  jjaakola-aiven

  authored
  dc35ee4

  Copy full SHA for dc35ee4

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/AbstractSourceTask.java

  Show description for 7aa64fc
  

  Claudenw

  and

  jjaakola-aiven

  authored
  7aa64fc

  Copy full SHA for 7aa64fc

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/AbstractSourceTask.java

  Show description for c25a877
  

  Claudenw

  and

  jjaakola-aiven

  authored
  c25a877

  Copy full SHA for c25a877

• Update s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java

  Show description for 37260b3
  

  Claudenw

  and

  jjaakola-aiven

  authored
  37260b3

  Copy full SHA for 37260b3

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/AbstractSourceTask.java

  Show description for 21f713a
  

  Claudenw

  and

  jjaakola-aiven

  authored
  21f713a

  Copy full SHA for 21f713a

• Update s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/S3SourceTask.java

  Show description for eb2c051
  

  Claudenw

  and

  jjaakola-aiven

  authored
  eb2c051

  Copy full SHA for eb2c051

• Update s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/utils/SourceRecordIterator.java

  Show description for a9d9380
  

  Claudenw

  and

  muralibasani

  authored
  a9d9380

  Copy full SHA for a9d9380

• changes as per review requests

  

  ¨Claude

  committed
  4f3f896

  Copy full SHA for 4f3f896

• fix for javadoc

  

  ¨Claude

  committed
  45bd6fd

  Copy full SHA for 45bd6fd

• Merge remote-tracking branch 'refs/remotes/upstream/polling_efficiency' into polling_efficiency

  

  ¨Claude

  committed
  08c3917

  Copy full SHA for 08c3917

• initial changes

  

  ¨Claude

  committed
  316a824

  Copy full SHA for 316a824

• merged files for KCON-57

  

  ¨Claude

  committed
  c69bb65

  Copy full SHA for c69bb65

• fixed merge issues

  

  ¨Claude

  committed
  2637f64

  Copy full SHA for 2637f64

• Merge remote-tracking branch 'origin/s3-source-release' into offsetmgr3

  

  ¨Claude

  committed
  99ffebf

  Copy full SHA for 99ffebf

• Added handling of processed Offsets

  

  ¨Claude

  committed
  5510586

  Copy full SHA for 5510586

Commits on Jan 10, 2025

• updates as per review

  

  ¨Claude

  committed
  3e948ba

  Copy full SHA for 3e948ba

• removed unused methods

  

  ¨Claude

  committed
  81d46a4

  Copy full SHA for 81d46a4

Commits on Jan 14, 2025

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/OffsetManager.java

  Show description for 96d1523
  

  Claudenw

  and

  muralibasani

  authored
  96d1523

  Copy full SHA for 96d1523

• Update commons/src/test/java/io/aiven/kafka/connect/common/source/OffsetManagerTest.java

  Show description for e429d8a
  

  Claudenw

  and

  muralibasani

  authored
  e429d8a

  Copy full SHA for e429d8a

• Update s3-source-connector/src/main/java/io/aiven/kafka/connect/s3/source/utils/S3OffsetManagerEntry.java

  Show description for 1d4b5e4
  

  Claudenw

  and

  muralibasani

  authored
  1d4b5e4

  Copy full SHA for 1d4b5e4

• Update s3-source-connector/src/test/java/io/aiven/kafka/connect/s3/source/utils/S3OffsetManagerEntryTest.java

  Show description for e4187f5
  

  Claudenw

  and

  muralibasani

  authored
  e4187f5

  Copy full SHA for e4187f5

• Update commons/src/main/java/io/aiven/kafka/connect/common/source/OffsetManager.java

  Show description for b8a64d3
  

  Claudenw

  and

  muralibasani

  authored
  b8a64d3

  Copy full SHA for b8a64d3

• fixed topicName and bucketName

  

  ¨Claude

  committed
  cd1f25f

  Copy full SHA for cd1f25f

• Changes as per review

  

  ¨Claude

  committed
  cd2650a

  Copy full SHA for cd2650a

• fixed spotless errors

  

  ¨Claude

  committed
  b444b44

  Copy full SHA for b444b44

Commits on Jan 15, 2025

• Merge branch 's3-source-release' into KCON-57_place_OffsetManager_in_commons

  

  ¨Claude

  committed
  a90fdcb

  Copy full SHA for a90fdcb

Commits on Jan 16, 2025

• modified to solve data change errors

  

  ¨Claude

  committed
  394f2d1

  Copy full SHA for 394f2d1