Adds the rest of the kafka producer properties

hitchan · Apr 23, 2020 · 3286c54 · 3286c54
1 parent 40e2490
commit 3286c54
Show file tree

Hide file tree

Showing 3 changed files with 212 additions and 206 deletions.
diff --git a/LICENSE b/LICENSE
diff --git a/src/main/java/com/frit/keycloak/kafka/KafkaConfiguration.java b/src/main/java/com/frit/keycloak/kafka/KafkaConfiguration.java
@@ -9,14 +9,66 @@ public interface KafkaConfiguration {
 
     String getBootstrapServers();
 
-    String getRetries();
+    String getClientDnsLookup();
+
+    String getMetadataMaxAge();
 
     String getBatchSize();
 
+    String getAcknowledgments();
+
     String getLinger();
 
+    String getRequestTimeout();
+
+    String getDeliveryTimeout();
+
+    String getClientId();
+
+    String getSendBuffer();
+
+    String getReceiveBuffer();
+
+    String getMaxRequestSize();
+
+    String getReconnectBackoff();
+
+    String getReconnectBackoffMax();
+
+    String getMaxBlock();
+
     String getBufferMemory();
 
+    String getRetryBackoff();
+
+    String getCompressionType();
+
+    String getMetricsSampleWindow();
+
+    String getMetricsNumberSamples();
+
+    String getMetricsRecordingLevel();
+
+    String getMetricReporterClasses();
+
+    String getMaxInFlightRequestsPerConnection();
+
+    String getRetriesConfig();
+
+    String getConnectionsMaxIdle();
+
+    String getPartitionerClass();
+
+    String getInterceptorClasses();
+
+    String getEnableIdempotence();
+
+    String getTransactionalTimeout();
+
+    String getTransactionalId();
+
+    String getSecurityProviders();
+
     String getSchemaRegistryUrl();
 
     String getUserTopic();