Commit 1a315a1
File tree
224 files changed
+405
-483
lines changed- common
- src
- main/kotlin/org/neo4j/connectors/kafka
- configuration
- helpers
- connect
- data
- events
- extensions
- service
- errors
- sink/strategy
- utils
- test/kotlin/org/neo4j/connectors/kafka
- configuration
- helpers
- data
- service
- errors
- sink/strategy
- utils
- legacy-connectors
- src
- main/kotlin/streams/kafka/connect
- sink
- source
- test/kotlin/streams/kafka/connect
- sink
- source
- packaging
- src/main
- assemblies
- distributions/text
- config
- doc
- sink-connector
- src
- main/kotlin/org/neo4j/connectors/kafka/sink
- test/kotlin/org/neo4j/connectors/kafka/sink
- sink
- src
- main/kotlin/org/neo4j/connectors/kafka/sink
- converters
- strategy
- utils
- test/kotlin/org/neo4j/connectors/kafka/sink
- converters
- strategy
- utils
- source-connector
- src
- main/kotlin/org/neo4j/connectors/kafka/source
- test/kotlin/org/neo4j/connectors/kafka/source
- source
- src
- main/kotlin/org/neo4j/connectors/kafka/source
- utils
- test/kotlin/org/neo4j/connectors/kafka/source
- testing/src
- main/kotlin/org/neo4j/connectors/kafka/testing
- assertions
- format
- avro
- json
- protobuf
- string
- kafka
- sink
- source
- test/kotlin/org/neo4j/connectors/kafka/testing
- sink
- source
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
224 files changed
+405
-483
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
258 | 258 | | |
259 | 259 | | |
260 | 260 | | |
261 | | - | |
| 261 | + | |
262 | 262 | | |
263 | | - | |
| 263 | + | |
264 | 264 | | |
265 | 265 | | |
266 | 266 | | |
| |||
277 | 277 | | |
278 | 278 | | |
279 | 279 | | |
| 280 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | | - | |
| 2 | + | |
3 | 3 | | |
4 | 4 | | |
5 | 5 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
Lines changed: 1 addition & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
1 | 1 | | |
2 | 2 | | |
3 | | - | |
| 3 | + | |
4 | 4 | | |
5 | 5 | | |
6 | 6 | | |
| |||
0 commit comments