v3.0.0 Dependency Update Release

3.0.0 (03/20/2020)

Various internal dependencies updated to resolve upstream CVEs. No feature or logic changes. See note about possible breaking change for a removed dependency below -- Major revision number updated to err on the safe side.

Possible Breaking Dependency Change

• Removed org.apache.logging.log4j dependency, instead relying on the org.slf4j logging interface/facade dependency explicitly.

  • If your project was NOT depending on this transitive dependency, no changes are required to upgrade.
  • If your project WAS depending on this transitive dependency, you may need to add it to your own project:

  <dependency>
      <groupId>org.apache.logging.log4j</groupId>
      <artifactId>log4j-api</artifactId>
      <version>2.12.1</version>
  </dependency>
  <dependency>
      <groupId>org.apache.logging.log4j</groupId>
      <artifactId>log4j-core</artifactId>
      <version>2.12.1</version>
  </dependency>
  <dependency>
      <groupId>org.apache.logging.log4j</groupId>
      <artifactId>log4j-slf4j-impl</artifactId>
      <version>2.12.1</version>
  </dependency>

Internal Dependency Updates

• Checkstyle plugin from 8.19 -> 8.24
• com.fasterxml.jackson.core from 2.9.9 -> 2.10.2
• org.apache.logging.log4j from 2.11.2 -> 2.12.1
• org.apache.httpcomponents from 4.5.8 -> 4.5.11
• com.google.guava:guava from 27.1-jre -> 28.2-jre
• org.eclipse.jetty:jetty-server (test dependency) from 9.4.17.v20190418 -> 9.4.27.v20200227
• org.mockito:mockito-core (test dependency) from 2.27.0 -> 2.28.2

v2.1.0 Feature Release

2.1.0 (06/26/2019)

New Features

• Added support to retrieve information about the Kafka-Connect server being queried.

    /**
     * Retrieve details about the Kafka-Connect service itself.
     * @return ConnectServerVersion
     */
    public ConnectServerVersion getConnectServerVersion()

• Added support for Expanded Connectors API Endpoint KIP-465.

Only supported by Kafka-Connect servers running version 2.3.0+ the following methods were added:

    /**
     * Get a list of deployed connectors, including the status for each connector.
     * https://docs.confluent.io/current/connect/references/restapi.html#get--connectors
     *
     * Requires Kafka-Connect 2.3.0+
     *
     * @return All deployed connectors, and their respective statuses.
     */
    public ConnectorsWithExpandedStatus getConnectorsWithExpandedStatus()

    /**
     * Get a list of deployed connectors, including the definition for each connector.
     * https://docs.confluent.io/current/connect/references/restapi.html#get--connectors
     *
     * Requires Kafka-Connect 2.3.0+
     *
     * @return All deployed connectors, and their respective definition.
     */
    public ConnectorsWithExpandedInfo getConnectorsWithExpandedInfo()

    /**
     * Get a list of deployed connectors, including all metadata available.
     * Currently includes both 'info' {@see getConnectorsWithExpandedInfo} and 'status' {@see getConnectorsWithExpandedStatus}
     * metadata.
     * https://docs.confluent.io/current/connect/references/restapi.html#get--connectors
     *
     * Requires Kafka-Connect 2.3.0+
     *
     * @return All deployed connectors, and their respective metadata.
     */
    public ConnectorsWithExpandedMetadata getConnectorsWithAllExpandedMetadata()

v2.0.2 Internal dependency update

2.0.2 (06/06/2019)

Internal Dependency Updates

• Update Jackson dependency from 2.9.8 to 2.9.9 CVE-2019-12086.

v2.0.1 Bugfix Release

2.0.1 (04/23/2019)

Bugfix

• Updated ConnectorPluginConfigValidationResults classes to be publicly scoped. Thanks tchiotludo!

Internal Dependency Updates

• Updated Google Guava from 27.0.1-JRE to 27.1-JRE
• Updated HttpComponents from 4.5.7 to 4.5.8

Bugfix / Breaking Change

2.0.0 (04/05/2019)

Bugfix / Breaking Change

PR: Fix connector tasks & plugins query

tchiotludo discovered and fixed a bug in the KafkaConnectClient::getConnectorPlugins() and
KafkaConnectClient::getConnectorTasks() client methods.

Previous to this version these methods incorrectly returned a
Collection<Map<>> instead of Collection<ConnectorPlugin> and Collection<Task> respectively.

This release fixes these two methods to return the correct types as defined by their signatures. Any users of this library who were interacting with this incorrect return type will need to update their code for this release.

v1.3.0 Feature Release

1.3.0 (02/06/2019)

New Features

• Added ability to configure sending a client certificate for Kafka-Connect REST servers that are configured to authenticate client certificates.

v1.2.0 Feature Release

1.2.0 (02/02/2019)

New Features

• Added ability to authenticate with Kafka-Connect REST endpoints utilizing Basic-Authentication.

v1.1.0

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.

v1.0.3

1.0.3 (04/16/2018)

• More specific exception classes thrown when requests fail.

v1.0.2

1.0.2 (04/12/2018)

• More specific exception classes thrown when requests fail.
• Mark internal classes as not final to allow mocking more easily.