1.1.0 (01/30/2019)
New Features
- Added ability to communicate with Kafka-Connect REST endpoints using SSL.
/*
* Create a new configuration object.
*/
final Configuration configuration = new Configuration("https://hostname.for.kafka-connect.service.com:8083");
/*
* If your JVM's TrustStore has already been updated to accept the certificate installed on your Kafka-Connect
* instance, then no further configuration is required. Typically this is done using the 'key-tool' command.
*
* Alternatively, you can configure the path to JKS formatted TrustStore file to validate the host's certificate
* with.
*/
configuration.useTrustStore(
new File("/path/to/truststore.jks"), "TrustStorePasswordHere or NULL"
);
/*
* Optionally instead of providing a TrustStore, you can disable all verifications of Kafka-Connect's SSL certificates.
*
* Doing this is HIGHLY DISCOURAGED!
*/
//configuration.useInsecureSslCertificates();
/*
* Create an instance of KafkaConnectClient, passing your configuration.
*/
final KafkaConnectClient client = new KafkaConnectClient(configuration);Internal Dependency Updates
- Updated Guava from 24.0-JRE to 27.0-JRE for CVE-2018-10237.
- Replace internal calls to Guava's Preconditions with Objects.requireNonNull()
- Jackson updated from 2.9.5 to 2.9.8 for several CVEs.
