Skip to content

Commit

Permalink
Merge pull request #96 from ably/release/2.1.0
Browse files Browse the repository at this point in the history
Release/2.1.0
  • Loading branch information
ikbalkaya authored Nov 9, 2022
2 parents 769a6c8 + f73f909 commit cbee26f
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 3 deletions.
10 changes: 9 additions & 1 deletion CHANGELOG.md
Original file line number Diff line number Diff line change
@@ -1,6 +1,14 @@
# Changelog

# Changelog
## [v2.1.0](https://github.com/ably/kafka-connect-ably/tree/v2.1.0)

[Full Changelog](https://github.com/ably/kafka-connect-ably/compare/v2.0.3...v2.1.0)

**Implemented enhancements:**

- Provide ability for users to channel failed messages into a dead letter queue [\#90](https://github.com/ably/kafka-connect-ably/issues/90)
- Provide ability to skip a record when a key is absent and channel is configured with a key [\#85](https://github.com/ably/kafka-connect-ably/issues/85)
- Update docker-compose to include latest version of images [\#81](https://github.com/ably/kafka-connect-ably/issues/81)

## [v2.0.3](https://github.com/ably/kafka-connect-ably/tree/v2.0.3)

Expand Down
2 changes: 1 addition & 1 deletion README.md
Original file line number Diff line number Diff line change
Expand Up @@ -244,7 +244,7 @@ transforms.RecordKeyCheck.message.name = #{key}_message

`transforms.RecordKeyCheck.channel.name` must be exactly the same configuration as `channel` configuration in your connector. `transforms.RecordKeyCheck.message.name` is optional But when provided it must be set as exactly the same as `message.name` in your connector.

There is a separate [Dockerfile](https://github.com/ably/kafka-connect-ably/KeyCheckSMT/blob/prepare_connector_for_dlq_processing/Dockerfile) provided in this project which contains the custom SMT installation along with connector. If you want to build your own Docker image, you can copy the content of this to `Dockerfile` provided in this project. You can alternatively build your JAR from the [source code](https://github.com/ably/kafka-connect-ably/tree/prepare_connector_for_dlq_processing/KeyCheckSMT) and add it to your classpath.
There is a separate [Dockerfile](https://github.com/ably/kafka-connect-ably/blob/main/KeyCheckSMT/Dockerfile) provided in this project which contains the custom SMT installation along with connector. If you want to build your own Docker image, you can copy the content of this to `Dockerfile` provided in this project. You can alternatively build your JAR from the [source code](https://github.com/ably/kafka-connect-ably/blob/main/KeyCheckSMT) and add it to your classpath.
Please use this SMT only if you use `#{key}` in your configuration values for channel name or message name. If you do not use `#{key}` in your configuration values, you must not use this SMT.

Setting up dead letter queue for failed messages is out of scope of this document. We recommend you read [this blog post](https://www.confluent.io/en-gb/blog/kafka-connect-deep-dive-error-handling-dead-letter-queues/) to learn how to set up dead letter queue for failed messages.
Expand Down
2 changes: 1 addition & 1 deletion pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

<groupId>com.ably.kafka.connect</groupId>
<artifactId>kafka-connect-ably</artifactId>
<version>2.0.3</version>
<version>2.1.0</version>
<packaging>jar</packaging>

<properties>
Expand Down

0 comments on commit cbee26f

Please sign in to comment.