fixes #121 update the kafka-producer.yml and kafka-consumer.yml

kafka-common/src/test/resources/config/kafka-consumer.yml

@@ -20,6 +20,8 @@ properties:
   # security.protocol: ${kafka-consumer.security.protocol:SASL_SSL}
   # sasl.mechanism: ${kafka-consumer.sasl.mechanism:PLAIN}
   # sasl.jaas.config: "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${kafka-consumer.username:username}\" password=\"${kafka-consumer.password:password}\";"
+  # ssl.truststore.location: ${kafka-consumer.ssl.truststore.location:/truststore/kafka.server.truststore.jks}
+  # ssl.truststore.password: ${kafka-consumer.ssl.truststore.password:changeme}
   # ssl.endpoint.identification.algorithm: ${kafka-consumer.ssl.endpoint.identification.algorithm:algo-name}
   # Apache Kafka 2.3 clients or later will then read from followers that have matching broker.rack as the specified client.rack ID.
   # client.rack: ${kafka-consumer.client.rack:rack-name}
@@ -76,7 +78,11 @@ requestMaxBytes: ${kafka-consumer.requestMaxBytes:102400}
 requestTimeoutMs: ${kafka-consumer.requestTimeoutMs:1000}
 # Minimum bytes of records to accumulate before returning a response to a consumer request. Default 10MB
 fetchMinBytes: ${kafka-consumer.fetchMinBytes:-1}
-# amount of idle time before a consumer instance is automatically destroyed.
+# amount of idle time before a consumer instance is automatically destroyed. If you use the ActiveConsumer and do not
+# want to recreate the consumer instance for every request, increase this number to a bigger value. Default to 5 minutes
+# that is in sync with max.poll.interval.ms default value. When this value is increased to a value greater than 5 minutes,
+# the max.poll.interval.ms will be automatically increased as these two values are related although completely different.
 instanceTimeoutMs: ${kafka-consumer.instanceTimeoutMs:300000}
 # Amount of time to backoff when an iterator runs out of date.
 iteratorBackoffMs: ${kafka-consumer.iteratorBackoffMs:50}
+

kafka-common/src/test/resources/config/kafka-producer.yml

@@ -1,4 +1,3 @@
----
 # Generic configuration for Kafka producer.
 properties:
   # The sidecar does the serialization to byte array for both key and value
@@ -37,12 +36,14 @@ properties:
   # sasl.mechanism: ${kafka-producer.sasl.mechanism:PLAIN}
   # sasl.jaas.config: "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"${kafka-producer.username:username}\" password=\"${kafka-producer.password:password}\";"
   # ssl.endpoint.identification.algorithm: ${kafka-producer.ssl.endpoint.identification.algorithm:algo-name}
+  # ssl.truststore.location: ${kafka-producer.ssl.truststore.location:/truststore/kafka.server.truststore.jks}
+  # ssl.truststore.password: ${kafka-producer.ssl.truststore.password:changeme}
   # client.rack: ${kafka-producer.client.rack:rack-name}
   # basic authentication user:pass for the schema registry
   # basic.auth.user.info: ${kafka-producer.username:username}:${kafka-producer.password:password}
   # basic.auth.credentials.source: ${kafka-producer.basic.auth.credentials.source:USER_INFO}
   # If you have message that is bigger than 1 MB to produce, increase this value.
-  max.message.size: ${kafka-producer.max.message.size:1048576}
+  max.request.size: ${kafka-producer.max.request.size:1048576}
 
 # The default topic for the producer. Only certain producer implementation will use it.
 topic: ${kafka-producer.topic:portal-event}