diff --git a/.github/workflows/build.yml b/.github/workflows/build.yml
index 6ac6da0..7e2a9f9 100644
--- a/.github/workflows/build.yml
+++ b/.github/workflows/build.yml
@@ -18,10 +18,8 @@ jobs:
       max-parallel: 100
       matrix:
         spring_boot_version:
+          - 3.3.1
           - 3.2.2
-          - 3.1.6
-          - 3.0.13
-          - 2.7.18
     env:
       SPRING_BOOT_VERSION: ${{ matrix.spring_boot_version }}
       GRADLE_OPTS: "-Djava.security.egd=file:/dev/./urandom -Dorg.gradle.parallel=true"
diff --git a/CHANGELOG.md b/CHANGELOG.md
index b59aebd..e04f0cc 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -5,6 +5,15 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [0.29.0] - 2024-07-16
+
+### Added
+
+- Added Spring Boot 3.3 support.
+
+### Removed
+- Removed support for spring boot 3.1 and 2.7.
+
 ## [0.28.3] - 2024-02-20
 
 ### Changed
diff --git a/build.gradle b/build.gradle
index ee3084e..214518b 100644
--- a/build.gradle
+++ b/build.gradle
@@ -4,7 +4,7 @@ import org.eclipse.jgit.api.errors.RefAlreadyExistsException
 
 buildscript {
     if (!project.hasProperty("springBootVersion")) {
-        ext.springBootVersion = System.getenv("SPRING_BOOT_VERSION") ?: "2.7.18"
+        ext.springBootVersion = System.getenv("SPRING_BOOT_VERSION") ?: "3.2.2"
     }
     dependencies {
         classpath 'com.google.protobuf:protobuf-gradle-plugin:0.9.4'
diff --git a/build.libraries.gradle b/build.libraries.gradle
index 1b11d88..0e0d20f 100644
--- a/build.libraries.gradle
+++ b/build.libraries.gradle
@@ -1,6 +1,6 @@
 ext {
     protobufVersion = "3.24.0"
-    springBootVersion = "${System.getenv("SPRING_BOOT_VERSION") ?: '2.7.18'}"
+    springBootVersion = "${System.getenv("SPRING_BOOT_VERSION") ?: '3.2.2'}"
     libraries = [
             // version defined
             awaitility                      : 'org.awaitility:awaitility:4.2.0',
@@ -31,6 +31,7 @@ ext {
             commonsLang3                    : 'org.apache.commons:commons-lang3',
             flywayCore                      : 'org.flywaydb:flyway-core',
             flywayMysql                     : 'org.flywaydb:flyway-mysql',
+            flywayPostgresql                : 'org.flywaydb:flyway-database-postgresql',
             jacksonDatabind                 : 'com.fasterxml.jackson.core:jackson-databind',
             kafkaClients                    : 'org.apache.kafka:kafka-clients',
             lombok                          : 'org.projectlombok:lombok',
diff --git a/gradle.properties b/gradle.properties
index 1f6dd97..187e7df 100644
--- a/gradle.properties
+++ b/gradle.properties
@@ -1 +1 @@
-version=0.28.3
+version=0.29.0
diff --git a/tw-tkms-starter/build.gradle b/tw-tkms-starter/build.gradle
index 7b70c90..82f5228 100644
--- a/tw-tkms-starter/build.gradle
+++ b/tw-tkms-starter/build.gradle
@@ -55,9 +55,11 @@ dependencies {
     testImplementation project(":tw-tkms-test-starter")
 
     testImplementation libraries.awaitility
-    if (!springBootVersion.startsWith("2.6")) {
-        testImplementation libraries.flywayMysql
+    // If we are running on spring boot 3.3 or newer then we need to use the flyway-postgresql dependency.
+    if (!springBootVersion.startsWith("3.2")) {
+        testImplementation libraries.flywayPostgresql
     }
+    testImplementation libraries.flywayMysql
     testImplementation libraries.flywayCore
     testImplementation libraries.lombok
     testImplementation libraries.springBootStarterActuator
diff --git a/tw-tkms-starter/src/test/java/com/transferwise/kafka/tkms/PostgresEndToEndIntTest.java b/tw-tkms-starter/src/test/java/com/transferwise/kafka/tkms/PostgresEndToEndIntTest.java
index 821f952..c1e9a71 100644
--- a/tw-tkms-starter/src/test/java/com/transferwise/kafka/tkms/PostgresEndToEndIntTest.java
+++ b/tw-tkms-starter/src/test/java/com/transferwise/kafka/tkms/PostgresEndToEndIntTest.java
@@ -16,7 +16,7 @@ private static Stream<Arguments> compressionInput() {
     var arguments = new ArrayList<Arguments>();
 
     for (var deferUntilCommit : deferUntilCommits) {
-      arguments.add(Arguments.of(CompressionAlgorithm.GZIP, 112, 111, deferUntilCommit));
+      arguments.add(Arguments.of(CompressionAlgorithm.GZIP, 111, 110, deferUntilCommit));
       arguments.add(Arguments.of(CompressionAlgorithm.NONE, 1172, 1171, deferUntilCommit));
       arguments.add(Arguments.of(CompressionAlgorithm.LZ4, 135, 134, deferUntilCommit));
       arguments.add(Arguments.of(CompressionAlgorithm.SNAPPY, 164, 160, deferUntilCommit));