PROPERTIES(props):

    props.put(StreamsConfig.NUM_STREAM_THREADS_CONFIG, config.streamingThreads)
    props.put(StreamsConfig.REQUEST_TIMEOUT_MS_CONFIG, config.requestTimeoutMs)
    props.put(StreamsConfig.COMMIT_INTERVAL_MS_CONFIG, config.autoCommitEnableMs)
    props.put(StreamsConfig.DEFAULT_KEY_SERDE_CLASS_CONFIG, serdesConfig.byteArrSerde.getClass)
    props.put(StreamsConfig.DEFAULT_VALUE_SERDE_CLASS_CONFIG, serdesConfig.byteArrSerde.getClass)

    props.put(ProducerConfig.RETRIES_CONFIG, config.retries)
    props.put(ProducerConfig.RETRY_BACKOFF_MS_CONFIG, config.retriesBO)
    props.put(ProducerConfig.MAX_REQUEST_SIZE_CONFIG, config.maxRequestSize)
    props.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, config.requestTimeoutMs)
    props.put(ProducerConfig.LINGER_MS_CONFIG, config.lingerMs)
    props.put(ProducerConfig.BATCH_SIZE_CONFIG, config.recordBatchSize)

    props.put(ConsumerConfig.FETCH_MAX_BYTES_CONFIG, FETCH_MAX_BYTES.toString)
    props.put(ConsumerConfig.MAX_PARTITION_FETCH_BYTES_CONFIG, config.maxPartitionRequestSize)
    props.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, config.autoOffsetReset)
    props.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, config.maxPollMs)
    props.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, config.sessionTimeoutMs)

streamingThreads: 4
requestTimeoutMs: Integer.MAX_VALUE.toString
autoCommitEnableMs: 5000

retries: 5
retriesBO: 60000
maxRequestSize: 10485760 //10mb
requestTimeoutMs: Integer.MAX_VALUE.toString
lingerMs: 60000
recordBatchSize: 3000

fetchMaxBytes: 12
maxPartitionRequestSize: 12582912 //12mb
autoOffsetReset: earliest
maxPollMs: 150000
sessionTimeoutMs: 60000