From 86e1bbec3bde4b73c1f10f75306d4ae550a34883 Mon Sep 17 00:00:00 2001
From: Dharin Shah <8616130+Dharin-shah@users.noreply.github.com>
Date: Wed, 15 Mar 2023 11:32:58 +0530
Subject: [PATCH] fix

---
 .idea/misc.xml                                |  2 +-
 build.gradle                                  | 28 +++++++++++++------
 .../streams/processors/BufferedProcessor.java |  1 +
 3 files changed, 21 insertions(+), 10 deletions(-)

diff --git a/.idea/misc.xml b/.idea/misc.xml
index 39709a4..23e4e71 100644
--- a/.idea/misc.xml
+++ b/.idea/misc.xml
@@ -1,7 +1,7 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <project version="4">
   <component name="ExternalStorageConfigurationManager" enabled="true" />
-  <component name="ProjectRootManager" version="2" languageLevel="JDK_11" default="true" project-jdk-name="azul-11" project-jdk-type="JavaSDK">
+  <component name="ProjectRootManager" version="2" languageLevel="JDK_17" default="true" project-jdk-name="temurin-17" project-jdk-type="JavaSDK">
     <output url="file://$PROJECT_DIR$/out" />
   </component>
   <component name="ProjectType">
diff --git a/build.gradle b/build.gradle
index 928e714..142e99c 100644
--- a/build.gradle
+++ b/build.gradle
@@ -8,22 +8,32 @@ version '1.0-SNAPSHOT'
 repositories {
     mavenCentral()
     maven {
-        url "https://repo.spring.io/release"
+        url "https://packages.confluent.io/maven"
     }
-    maven {
-        url "https://repository.jboss.org/maven2"
+    mavenLocal()
+}
+
+java {
+    toolchain {
+        languageVersion = JavaLanguageVersion.of(17)
     }
 }
 
 dependencies {
-    testImplementation 'org.junit.jupiter:junit-jupiter-api:5.8.1'
-    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.8.1'
-    implementation 'org.apache.kafka:kafka-streams'
-    implementation 'org.apache.kafka:kafka-clients'
+    implementation 'org.projectlombok:lombok:1.18.22'
+    testImplementation 'org.junit.jupiter:junit-jupiter-api:5.9.2'
+    testRuntimeOnly 'org.junit.jupiter:junit-jupiter-engine:5.9.2'
+    implementation 'org.apache.kafka:kafka-streams:3.4.0'
+    implementation 'org.apache.kafka:kafka-clients:3.4.0'
     implementation('io.streamthoughts:azkarra-streams:0.9.2')
     compileOnly('io.streamthoughts:azkarra-metrics:0.9.2')
-    testImplementation 'org.apache.kafka:kafka-streams-test-utils'
-    testImplementation('org.junit.jupiter:junit-jupiter')
+    implementation 'org.rocksdb:rocksdbjni:7.0.4'
+    compileOnly('io.streamthoughts:azkarra-metrics:0.9.2')
+    implementation 'com.fasterxml.jackson.datatype:jackson-datatype-jsr310:2.13.3'
+    // Mapper & Lombok Compatibility Binding
+    compileOnly "org.projectlombok:lombok-mapstruct-binding:0.2.0"
+    testCompileOnly "org.projectlombok:lombok-mapstruct-binding:0.2.0"
+    testAnnotationProcessor "org.projectlombok:lombok-mapstruct-binding:0.2.0"
 }
 
 test {
diff --git a/src/main/java/streams/processors/BufferedProcessor.java b/src/main/java/streams/processors/BufferedProcessor.java
index 5774d41..7f46f2e 100644
--- a/src/main/java/streams/processors/BufferedProcessor.java
+++ b/src/main/java/streams/processors/BufferedProcessor.java
@@ -2,6 +2,7 @@
 
 import java.time.Duration;
 import java.util.ArrayList;
+import lombok.SneakyThrows;
 import org.apache.kafka.streams.processor.PunctuationType;
 import org.apache.kafka.streams.processor.api.Processor;
 import org.apache.kafka.streams.processor.api.ProcessorContext;