File tree 2 files changed +33
-7
lines changed
src/test/java/com/github/jcustenborder/kafka/connect/archive
2 files changed +33
-7
lines changed Original file line number Diff line number Diff line change 1
1
# Introduction
2
2
3
- Kafka Connect transform to assist with archiving to S3.
3
+ # Transformations
4
4
5
- ## Kafka 0.11.x and newer
6
-
7
- ``` properties
5
+ ## Archive
8
6
7
+ The Archive transformation is used to help preserve all of the data for a message when archived to S3.
9
8
10
- ```
9
+ ### Configuration
11
10
12
- ## Kafka 0.10.x and older
11
+ | Name | Type | Importance | Default Value | Validator | Documentation|
12
+ | ---- | ---- | ---------- | ------------- | --------- | -------------|
13
13
14
- ``` properties
15
14
15
+ #### Standalone Example
16
16
17
+ ``` properties
18
+ transforms =Archive
19
+ transforms.Archive.type =com.github.jcustenborder.kafka.connect.archive.Archive
20
+ # The following values must be configured.
21
+ ```
17
22
23
+ #### Distributed Example
24
+
25
+ ``` json
26
+ {
27
+ "name" : " connector1" ,
28
+ "config" : {
29
+ "connector.class" : " com.github.jcustenborder.kafka.connect.archive.Archive" ,
30
+ "transforms" : " Archive" ,
31
+ "transforms.Archive.type" : " com.github.jcustenborder.kafka.connect.archive.Archive" ,
32
+ }
33
+ }
18
34
```
19
35
Original file line number Diff line number Diff line change
1
+ package com .github .jcustenborder .kafka .connect .archive ;
2
+
3
+ import com .github .jcustenborder .kafka .connect .utils .BaseDocumentationTest ;
4
+
5
+ public class DocumentationTest extends BaseDocumentationTest {
6
+ @ Override
7
+ protected String [] packages () {
8
+ return new String []{this .getClass ().getPackage ().getName ()};
9
+ }
10
+ }
You can’t perform that action at this time.
0 commit comments