Среда: spring-boot.version - 1.5.9.RELEASE spring-kafka.version - 1.2.0.RELEASE Клиентская версия экземпляра Kafka lib - kafka-clients-0.10.2.0.jar
В KafkaПриложение Spring, не может отправить сообщение от производителя экземпляру kafka
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s)
for testtopicname-0: 60018 ms has passed since last append
Я также увеличил свойство тайм-аута, но это не помогло либо
Мало реквизитов конфигурации производителя:
props.put(ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG, 60000);
props.put(ProducerConfig.RETRIES_CONFIG, 3);
props.put(ProducerConfig.BATCH_SIZE_CONFIG, 1);
props.put(ProducerConfig.LINGER_MS_CONFIG, 5);
Снимок кода для отправки сообщения:
kafkaTemplate.send(message)
Ниже приведена конфигурация, специфичная для SSL
Kafka Instance :
ssl.cipher.suites = null
ssl.client.auth = none
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS
Spring producer :
ssl.cipher.suites = null
ssl.enabled.protocols = [TLSv1.2, TLSv1.1, TLSv1]
ssl.endpoint.identification.algorithm = null
ssl.key.password = null
ssl.keymanager.algorithm = SunX509
ssl.keystore.location = null
ssl.keystore.password = null
ssl.keystore.type = JKS
ssl.protocol = TLS
ssl.provider = null
ssl.secure.random.implementation = null
ssl.trustmanager.algorithm = PKIX
ssl.truststore.location = null
ssl.truststore.password = null
ssl.truststore.type = JKS