Skip to content

Commit 60e09a8

Browse files
committed
Docs: Changelog updates
And arvo -> avro changes
1 parent 491c485 commit 60e09a8

File tree

3 files changed

+8
-2
lines changed

3 files changed

+8
-2
lines changed

docs/changelog.md

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,12 @@
44

55
## 0.2
66

7+
* [[KAFKA-49](https://jira.mongodb.org/browse/KAFKA-49) Added a source record key (resume token)
8+
* [[KAFKA-44](https://jira.mongodb.org/browse/KAFKA-44) CDC handle `$v` update fields from oplog
9+
* [[KAFKA-41](https://jira.mongodb.org/browse/KAFKA-41) Fix confluent-hub zip
10+
* [[KAFKA-37](https://jira.mongodb.org/browse/KAFKA-37) Ensure sink operations are ordered
11+
* [[KAFKA-36](https://jira.mongodb.org/browse/KAFKA-36) Updated docker demo
12+
* [[KAFKA-35](https://jira.mongodb.org/browse/KAFKA-35) Added AVRO support for nested complex types
713
* [[KAFKA-34](https://jira.mongodb.org/browse/KAFKA-34)] DocumentIdAdder can be anywhere in the post processors list
814

915
## 0.1 - Initial release

docs/sink.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -235,7 +235,7 @@ following Java type mappings:
235235
- long myTimestampMicrosField;
236236

237237
See [this discussion](https://github.com/mongodb/mongo-kafka/issues/5) if you are interested in some more details.
238-
Note: ARVO 1.9.0 will support native Java 8 date time types.
238+
Note: AVRO 1.9.0 will support native Java 8 date time types.
239239
Logical types can only be supported for **AVRO** and **JSON + Schema** data.
240240

241241

src/integrationTest/java/com/mongodb/kafka/connect/MongoSinkConnectorTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -65,7 +65,7 @@ void testASimpleProducerSmokeTest() {
6565

6666
@Test
6767
@DisplayName("Ensure sink connect saves data to MongoDB")
68-
void testSinkSavesArvoDataToMongoDB() {
68+
void testSinkSavesAvroDataToMongoDB() {
6969
Stream<TweetMsg> tweets = IntStream.range(0, 100).mapToObj(i ->
7070
TweetMsg.newBuilder().setId$1(i)
7171
.setText(format("test tweet %s end2end testing apache kafka <-> mongodb sink connector is fun!", i))

0 commit comments

Comments
 (0)