diff --git a/kafka-common/src/test/resources/config/kafka-consumer.yml b/kafka-common/src/test/resources/config/kafka-consumer.yml index d5ced7a..58af470 100644 --- a/kafka-common/src/test/resources/config/kafka-consumer.yml +++ b/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} + diff --git a/kafka-common/src/test/resources/config/kafka-producer.yml b/kafka-common/src/test/resources/config/kafka-producer.yml index e57a5b3..e3ee3fe 100644 --- a/kafka-common/src/test/resources/config/kafka-producer.yml +++ b/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}