Kafka ssl Producer EOFException während Producer.send von Cloud Foundry

Question

In Cloud Foundry kann ich eine Nachricht an non ssl url ("kafkaURL: 9092") erstellen. Aber es funktioniert nicht für ssl URL ("kafkaURL: 9093").

Kafka Server Version 0.10.0.1 und Client Version 0.10.0.0.

Hier sind die Eigenschaften I verwendet:

props.put(org.apache.kafka.clients.producer.ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, config.getString("obs_q_and_a_db.kafka.metadataBrokerList")) 
props.put(org.apache.kafka.clients.producer.ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer]) 
props.put(org.apache.kafka.clients.producer.ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, classOf[StringSerializer]) 
props.put(CommonClientConfigs.SECURITY_PROTOCOL_CONFIG, "SSL") 
props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, "mySslFolder/answersapi.kafka.client.keystore.jks") 
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, "sslTruststorePassword")) 
props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, "mySslFolder/answersapi.kafka.client.truststore.jks") 
props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG, "sslKeystorePassword") 
props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG, "sslKeyPassword") 
props.setProperty("metadata.broker.list", "kafkaURL:9093")) 
props.setProperty("serializer.class", serializerClass) 
props.setProperty("message.send.max.retries", maxRetries.toString) 
props.setProperty("request.required.acks", requiredAcks.toString) 
props.setProperty("producer.type", producerType) 
props.setProperty("batch.num.messages", batchNumMessages.toString) 

Die gleichen Eigenschaften und die gleichen cert-Dateien (Trusts, Schlüsselspeicher-Dateien), wenn sie von Kafka auf dem kafka Server funktioniert mit folgendem Befehl in Shell Shell verwendet:

kafka-console-producer --broker-list kafkaURL:9093 --producer.config config --topic myTopicName 

Und hier ist der Fehler:

2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT java.io.EOFException 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at org.apache.kafka.common.network.NetworkReceive.readFromReadableChannel(NetworkReceive.java:99) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.network.BlockingChannel.readCompletely(BlockingChannel.scala:129) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.network.BlockingChannel.receive(BlockingChannel.scala:120) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:77) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:74) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.SyncProducer.send(SyncProducer.scala:119) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:59) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.BrokerPartitionInfo.updateInfo(BrokerPartitionInfo.scala:82) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.async.DefaultEventHandler$$anonfun$handle$1.apply$mcV$sp(DefaultEventHandler.scala:68) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.utils.CoreUtils$.swallow(CoreUtils.scala:79) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.utils.Logging$class.swallowError(Logging.scala:106) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.utils.CoreUtils$.swallowError(CoreUtils.scala:51) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:68) 
2017-01-18T12:03:29.78-0600 [APP/PROC/WEB/0]OUT  at kafka.producer.Producer.send(Producer.scala:77) 

Answer 1

Unsere Kafka-Client-Code-Version: "0.9.0.1" funktioniert nicht mehr, als der Server auf 0.10.0.1 verschoben wurde Als wir unseren Client-Code auf 0.10.0.0 änderten, erhielten wir immer noch die gleiche EOFileException Es wurde behoben, als wir veraltete Klassen ersetzten kafka.producer {KeyedMessage, Producer, ProducerConfig} mit neuen 0.10.0-Klassen org.apache.kafka.clients.producer {ProducerRecord, KafkaProducer, ProducerConfig} bzw. Übrigens funktionieren alte veraltete Klassen gut, wenn sie auf nicht-SSL verweisen url, scheitern sie nur, wenn sie auf Secured Kafka URL

zeigen