Package com.networknt.kafka.common

Class KafkaProducerConfig

  • public class KafkaProducerConfig
extends Object
    A Kafka setting configuration file. It get from defined resource yml file in resources/config folder or externalized config folder. This config is for both producer and consumer and for each individual application, it might have only producer or consumer depending on the nature of the application.
    Author:
    Steve Hu

    • Constructor Detail

      • KafkaProducerConfig

        public KafkaProducerConfig()

    • Method Detail

      • getAcks

        public String getAcks()

      • setAcks

        public void setAcks​(String acks)

      • getRetries

        public int getRetries()

      • setRetries

        public void setRetries​(int retries)

      • getBatchSize

        public int getBatchSize()

      • setBatchSize

        public void setBatchSize​(int batchSize)

      • getLingerMs

        public int getLingerMs()

      • setLingerMs

        public void setLingerMs​(int lingerMs)

      • getBufferMemory

        public long getBufferMemory()

      • setBufferMemory

        public void setBufferMemory​(long bufferMemory)

      • getKeySerializer

        public String getKeySerializer()

      • setKeySerializer

        public void setKeySerializer​(String keySerializer)

      • getValueSerializer

        public String getValueSerializer()

      • setValueSerializer

        public void setValueSerializer​(String valueSerializer)

      • isEnableAutoCommit

        public boolean isEnableAutoCommit()

      • setEnableAutoCommit

        public void setEnableAutoCommit​(boolean enableAutoCommit)

      • getSessionTimeout

        public int getSessionTimeout()

      • setSessionTimeout

        public void setSessionTimeout​(int sessionTimeout)

      • getAutoOffsetreset

        public String getAutoOffsetreset()

      • setAutoOffsetreset

        public void setAutoOffsetreset​(String autoOffsetreset)

      • getBootstrapServers

        public String getBootstrapServers()

      • setBootstrapServers

        public void setBootstrapServers​(String bootstrapServers)

      • getKeyDeSerializer

        public String getKeyDeSerializer()

      • setKeyDeSerializer

        public void setKeyDeSerializer​(String keyDeSerializer)

      • getValueDeSerializer

        public String getValueDeSerializer()

      • setValueDeSerializer

        public void setValueDeSerializer​(String valueDeSerializer)

      • getTopic

        public String getTopic()

      • setTopic

        public void setTopic​(String topic)

      • getTransactionTimeoutMs

        public int getTransactionTimeoutMs()

      • setTransactionTimeoutMs

        public void setTransactionTimeoutMs​(int transactionTimeoutMs)

      • getTransactionId

        public String getTransactionId()

      • setTransactionId

        public void setTransactionId​(String transactionId)

      • getTransactionalIdExpirationMs

        public int getTransactionalIdExpirationMs()

      • setTransactionalIdExpirationMs

        public void setTransactionalIdExpirationMs​(int transactionalIdExpirationMs)

      • isInjectOpenTracing

        public boolean isInjectOpenTracing()

      • setInjectOpenTracing

        public void setInjectOpenTracing​(boolean injectOpenTracing)

      • isInjectCallerId

        public boolean isInjectCallerId()

      • setInjectCallerId

        public void setInjectCallerId​(boolean injectCallerId)

      • isEnableIdempotence

        public boolean isEnableIdempotence()

      • setEnableIdempotence

        public void setEnableIdempotence​(boolean enableIdempotence)

      • getMaxInFlightRequestsPerConnection

        public int getMaxInFlightRequestsPerConnection()

      • setMaxInFlightRequestsPerConnection

        public void setMaxInFlightRequestsPerConnection​(int maxInFlightRequestsPerConnection)