fix(init): rename java package from "de.otto.messaging.kafka.e2ee" to…

… "de.otto.kafka.messaging.e2ee" so it matches the artifactId BREAKING CHANGE: package names have changed to "de.otto.kafka.messaging.e2ee"
otto-de · Sep 21, 2023 · b69f69d · b69f69d
1 parent 7ce62a1
commit b69f69d
Show file tree

Hide file tree

Showing 75 changed files with 218 additions and 211 deletions.
diff --git a/docs/CACHING.md b/docs/CACHING.md
@@ -8,7 +8,7 @@ So in case of a downtime of the central vault the operation of your service is n
 ## Example for a 2nd-Level Vault Cache based on AWS Parameter Store
 
 ```java
-import de.otto.messaging.kafka.e2ee.vault.SecondLevelCacheStorage;
+import de.otto.kafka.messaging.e2ee.vault.SecondLevelCacheStorage;
 
 class SsmVaultCacheStorage implements SecondLevelCacheStorage {
 
@@ -63,7 +63,7 @@ class TheApp {
 ## Example for a 2nd-Level Vault Cache based on AWS Secret Manager
 
 ```java
-import de.otto.messaging.kafka.e2ee.vault.SecondLevelCacheStorage;
+import de.otto.kafka.messaging.e2ee.vault.SecondLevelCacheStorage;
 
 class SecretManagerVaultCacheStorage implements SecondLevelCacheStorage {
 

diff --git a/docs/USAGE.md b/docs/USAGE.md
@@ -8,6 +8,14 @@
 * [Caching](#caching)
 * [Key Rotation](#key-rotation)
 
+## Include Library to your build
+
+```groovy
+dependencies {
+    implementation "de.otto:kafka-messaging-e2ee:1.0.2"
+}
+```
+
 ## Step 0: create an EncryptionKeyProvider
 
 ### Option 1: Use SingleTopicVaultEncryptionKeyProviderConfig for simple use cases.
@@ -73,8 +81,8 @@ class Example {
 
 ### Step 1: create a EncryptionService and/or DecryptionService
 
-The main class you need is a [EncryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/EncryptionService.java)
-and/or [DecryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/DecryptionService.java).
+The main class you need is a [EncryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/EncryptionService.java)
+and/or [DecryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/DecryptionService.java).
 
 ```java
 class Example {
@@ -172,11 +180,11 @@ class Example {
 
 ### Step 1: create a SingleTopicFieldLevelEncryptionService and/or SingleTopicFieldLevelDecryptionService
 
-The main class you need is a [SingleTopicFieldLevelEncryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/fieldlevel/SingleTopicFieldLevelEncryptionService.java)
-and/or [SingleTopicFieldLevelDecryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/fieldlevel/SingleTopicFieldLevelDecryptionService.java).
+The main class you need is a [SingleTopicFieldLevelEncryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/fieldlevel/SingleTopicFieldLevelEncryptionService.java)
+and/or [SingleTopicFieldLevelDecryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/fieldlevel/SingleTopicFieldLevelDecryptionService.java).
 
-You can also use the classes [FieldLevelEncryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/fieldlevel/FieldLevelEncryptionService.java)
-and/or [FieldLevelDecryptionService](../src/main/java/de/otto/messaging/kafka/e2ee/fieldlevel/FieldLevelDecryptionService.java).
+You can also use the classes [FieldLevelEncryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/fieldlevel/FieldLevelEncryptionService.java)
+and/or [FieldLevelDecryptionService](../src/main/java/de/otto/kafka/messaging/e2ee/fieldlevel/FieldLevelDecryptionService.java).
 
 ```java
 class Example {

diff --git a/examples/README.md b/examples/README.md
@@ -16,7 +16,7 @@ cd /repos/kafka-messaging-e2ee/examples
 
 ```bash
 ## (optional) clean old versions of this libraries
-rm -rfv $HOME/.m2/repository/de/otto/messaging-kafka-e2ee
+rm -rfv $HOME/.m2/repository/de/otto/kafka-messaging-e2ee
 
 ## update the libraries in local maven repository
 cd /repos/kafka-messaging-e2ee

diff --git a/examples/build.gradle b/examples/build.gradle
@@ -4,7 +4,7 @@ plugins {
 }
 
 ext {
-    kafkaE2eeLibraryVersion = "1.0.0"
+    kafkaE2eeLibraryVersion = "1.0.2"
 }
 
 dockerCompose {

diff --git a/examples/springboot-fieldlevel-multiple/build.gradle b/examples/springboot-fieldlevel-multiple/build.gradle
@@ -4,7 +4,7 @@ plugins {
     id 'io.spring.dependency-management' version '1.1.0'
 }
 
-group = 'de.otto.messaging.kafka.e2ee.examples'
+group = 'de.otto.kafka.messaging.e2ee.examples'
 version = '0.0.1-SNAPSHOT'
 sourceCompatibility = '17'
 
@@ -30,7 +30,7 @@ dependencies {
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.kafka:spring-kafka-test'
 
-    // include our messaging.kafka.e2ee lib (run "./gradlew clean build publishToMavenLocal" beforehand)
+    // include our kafka-messaging-e2ee lib (run "./gradlew publishToMavenLocal" beforehand)
     implementation "de.otto:kafka-messaging-e2ee:${kafkaE2eeLibraryVersion}"
 }
 

diff --git a/...src/main/java/de/otto/springboot/example/fieldlevel/multiple/KafkaListenerTopicThree.java b/...src/main/java/de/otto/springboot/example/fieldlevel/multiple/KafkaListenerTopicThree.java
@@ -4,7 +4,7 @@
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelDecryptionService;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelDecryptionService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.kafka.annotation.KafkaListener;

diff --git a/...le/src/main/java/de/otto/springboot/example/fieldlevel/multiple/KafkaMessageProducer.java b/...le/src/main/java/de/otto/springboot/example/fieldlevel/multiple/KafkaMessageProducer.java
@@ -3,8 +3,8 @@
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelEncryptionService;
-import de.otto.messaging.kafka.e2ee.fieldlevel.SingleTopicFieldLevelEncryptionService;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelEncryptionService;
+import de.otto.kafka.messaging.e2ee.fieldlevel.SingleTopicFieldLevelEncryptionService;
 import java.time.Clock;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;

diff --git a/...a/de/otto/springboot/example/fieldlevel/multiple/config/KafkaEncryptionConfiguration.java b/...a/de/otto/springboot/example/fieldlevel/multiple/config/KafkaEncryptionConfiguration.java
@@ -1,16 +1,16 @@
 package de.otto.springboot.example.fieldlevel.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelDecryptionService;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelEncryptionService;
-import de.otto.messaging.kafka.e2ee.vault.CachedEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig;
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelDecryptionService;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelEncryptionService;
+import de.otto.kafka.messaging.e2ee.vault.CachedEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProviderConfig;
 import java.util.List;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

diff --git a/...java/de/otto/springboot/example/fieldlevel/multiple/config/KafkaEncryptionProperties.java b/...java/de/otto/springboot/example/fieldlevel/multiple/config/KafkaEncryptionProperties.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.fieldlevel.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig.VaultAppRole;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig.VaultAppRole;
 import java.util.List;
 import lombok.Getter;
 import lombok.Setter;

diff --git a/...ain/java/de/otto/springboot/example/fieldlevel/multiple/config/VaultFileCacheStorage.java b/...ain/java/de/otto/springboot/example/fieldlevel/multiple/config/VaultFileCacheStorage.java
@@ -1,6 +1,6 @@
 package de.otto.springboot.example.fieldlevel.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.vault.SecondLevelCacheStorage;
+import de.otto.kafka.messaging.e2ee.vault.SecondLevelCacheStorage;
 import java.io.BufferedReader;
 import java.io.FileNotFoundException;
 import java.io.FileReader;

diff --git a/...test/java/de/otto/springboot/example/fieldlevel/multiple/KafkaListenerTopicThreeTest.java b/...test/java/de/otto/springboot/example/fieldlevel/multiple/KafkaListenerTopicThreeTest.java
@@ -8,8 +8,8 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelDecryptionService;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelDecryptionService;
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.ExtendWith;

diff --git a/...rc/test/java/de/otto/springboot/example/fieldlevel/multiple/KafkaMessageProducerTest.java b/...rc/test/java/de/otto/springboot/example/fieldlevel/multiple/KafkaMessageProducerTest.java
@@ -7,11 +7,11 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider.KeyVersion;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.InitializationVectorFactory;
-import de.otto.messaging.kafka.e2ee.fieldlevel.FieldLevelEncryptionService;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider.KeyVersion;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.InitializationVectorFactory;
+import de.otto.kafka.messaging.e2ee.fieldlevel.FieldLevelEncryptionService;
 import java.time.Clock;
 import java.time.OffsetDateTime;
 import java.time.ZoneId;

diff --git a/examples/springboot-fullmessage-multiple/build.gradle b/examples/springboot-fullmessage-multiple/build.gradle
@@ -4,7 +4,7 @@ plugins {
     id 'io.spring.dependency-management' version '1.1.0'
 }
 
-group = 'de.otto.messaging.kafka.e2ee.examples'
+group = 'de.otto.kafka.messaging.e2ee.examples'
 version = '0.0.1-SNAPSHOT'
 sourceCompatibility = '17'
 
@@ -29,7 +29,7 @@ dependencies {
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.kafka:spring-kafka-test'
 
-    // include our messaging.kafka.e2ee lib (run "./gradlew clean build publishToMavenLocal" beforehand)
+    // include our kafka-messaging-e2ee lib (run "./gradlew publishToMavenLocal" beforehand)
     implementation "de.otto:kafka-messaging-e2ee:${kafkaE2eeLibraryVersion}"
 }
 

diff --git a/...age-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicOne.java b/...age-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicOne.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.multiple;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;

diff --git a/...e-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicThree.java b/...e-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicThree.java
@@ -1,11 +1,11 @@
 package de.otto.springboot.example.multiple;
 
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.kafka.annotation.KafkaListener;

diff --git a/...age-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicTwo.java b/...age-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaListenerTopicTwo.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.multiple;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import java.util.Map;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;

diff --git a/...sage-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaMessageProducer.java b/...sage-multiple/src/main/java/de/otto/springboot/example/multiple/KafkaMessageProducer.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.multiple;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;

diff --git a/...rc/main/java/de/otto/springboot/example/multiple/config/KafkaEncryptionConfiguration.java b/...rc/main/java/de/otto/springboot/example/multiple/config/KafkaEncryptionConfiguration.java
@@ -1,14 +1,14 @@
 package de.otto.springboot.example.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.vault.CachedEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig;
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.vault.CachedEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProviderConfig;
 import java.util.List;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

diff --git a/...e/src/main/java/de/otto/springboot/example/multiple/config/KafkaEncryptionProperties.java b/...e/src/main/java/de/otto/springboot/example/multiple/config/KafkaEncryptionProperties.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig.VaultAppRole;
+import de.otto.kafka.messaging.e2ee.vault.MultiTopicVaultEncryptionKeyProviderConfig.KafkaTopicConfigEntry;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig.VaultAppRole;
 import java.util.List;
 import lombok.Getter;
 import lombok.Setter;

diff --git a/...tiple/src/main/java/de/otto/springboot/example/multiple/config/VaultFileCacheStorage.java b/...tiple/src/main/java/de/otto/springboot/example/multiple/config/VaultFileCacheStorage.java
@@ -1,6 +1,6 @@
 package de.otto.springboot.example.multiple.config;
 
-import de.otto.messaging.kafka.e2ee.vault.SecondLevelCacheStorage;
+import de.otto.kafka.messaging.e2ee.vault.SecondLevelCacheStorage;
 import java.io.BufferedReader;
 import java.io.FileNotFoundException;
 import java.io.FileReader;

diff --git a/examples/springboot-fullmessage-single/build.gradle b/examples/springboot-fullmessage-single/build.gradle
@@ -4,7 +4,7 @@ plugins {
     id 'io.spring.dependency-management' version '1.1.0'
 }
 
-group = 'de.otto.messaging.kafka.e2ee.examples'
+group = 'de.otto.kafka.messaging.e2ee.examples'
 version = '0.0.1-SNAPSHOT'
 sourceCompatibility = '17'
 
@@ -29,7 +29,7 @@ dependencies {
     testImplementation 'org.springframework.boot:spring-boot-starter-test'
     testImplementation 'org.springframework.kafka:spring-kafka-test'
 
-    // include our messaging.kafka.e2ee lib (run "./gradlew clean build publishToMavenLocal" beforehand)
+    // include our kafka-messaging-e2ee lib (run "./gradlew publishToMavenLocal" beforehand)
     implementation "de.otto:kafka-messaging-e2ee:${kafkaE2eeLibraryVersion}"
 }
 

diff --git a/...message-single/src/main/java/de/otto/springboot/example/single/KafkaListenerTopicOne.java b/...message-single/src/main/java/de/otto/springboot/example/single/KafkaListenerTopicOne.java
@@ -1,11 +1,11 @@
 package de.otto.springboot.example.single;
 
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.kafka.annotation.KafkaListener;

diff --git a/...ssage-single/src/main/java/de/otto/springboot/example/single/KafkaListenerTopicThree.java b/...ssage-single/src/main/java/de/otto/springboot/example/single/KafkaListenerTopicThree.java
@@ -1,11 +1,11 @@
 package de.otto.springboot.example.single;
 
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
-import static de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_CIPHER_VALUE;
+import static de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper.KAFKA_HEADER_IV_VALUE;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.kafka.annotation.KafkaListener;

diff --git a/...lmessage-single/src/main/java/de/otto/springboot/example/single/KafkaMessageProducer.java b/...lmessage-single/src/main/java/de/otto/springboot/example/single/KafkaMessageProducer.java
@@ -1,8 +1,8 @@
 package de.otto.springboot.example.single;
 
-import de.otto.messaging.kafka.e2ee.AesEncryptedPayload;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.KafkaEncryptionHelper;
+import de.otto.kafka.messaging.e2ee.AesEncryptedPayload;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.KafkaEncryptionHelper;
 import java.time.LocalTime;
 import java.time.format.DateTimeFormatter;
 import java.util.ArrayList;

diff --git a/.../src/main/java/de/otto/springboot/example/single/config/KafkaEncryptionConfiguration.java b/.../src/main/java/de/otto/springboot/example/single/config/KafkaEncryptionConfiguration.java
@@ -1,13 +1,13 @@
 package de.otto.springboot.example.single.config;
 
-import de.otto.messaging.kafka.e2ee.DecryptionService;
-import de.otto.messaging.kafka.e2ee.EncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.EncryptionService;
-import de.otto.messaging.kafka.e2ee.vault.CachedEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.SingleTopicVaultEncryptionKeyProviderConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultConnectionConfig;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProvider;
-import de.otto.messaging.kafka.e2ee.vault.VaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.DecryptionService;
+import de.otto.kafka.messaging.e2ee.EncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.EncryptionService;
+import de.otto.kafka.messaging.e2ee.vault.CachedEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.SingleTopicVaultEncryptionKeyProviderConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultConnectionConfig;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProvider;
+import de.otto.kafka.messaging.e2ee.vault.VaultEncryptionKeyProviderConfig;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
-Original file line number
+Diff line change
@@ Expand Up / @@ -4,7 +4,7 @@ plugins { @@
     }
     ext {
-        kafkaE2eeLibraryVersion = "1.0.0"
+        kafkaE2eeLibraryVersion = "1.0.2"
     }
     dockerCompose {
@@ Expand Down @@