View Issue Details
| ID | Project | Category | View Status | Date Submitted | Last Update |
|---|---|---|---|---|---|
| 0003609 | SymmetricDS | New Feature | public | 2018-06-20 13:30 | 2019-04-24 14:46 |
| Reporter | josh-a-hicks | Assigned To | josh-a-hicks | ||
| Priority | normal | ||||
| Status | closed | Resolution | fixed | ||
| Product Version | 3.9.9 | ||||
| Target Version | 3.9.9 | Fixed in Version | 3.9.9 | ||
| Summary | 0003609: Kafka support as a load only node | ||||
| Description | Setup a Kafka node through the engine properties file similar to a load only node with some additional options for sending messages. Support for messages to be sent in XML, Json, Avro, or CSV. Can also send messages by batch or by row. Control over the topic of the message by channel or by table of the change. kafka.producer kafka.format (Values: XML, JSON, AVRO, CSV) kafka.message.by (Values : BATCH, ROW) kafka.topic.by (Values : CHANNEL, TABLE) | ||||
| Tags | No tags attached. | ||||
| related to | 0003015 | closed | SymmetricDS with KafkaConsumer. |
|
SymmetricDS: 3.9 ae87fc60 2018-06-20 09:30:43 Details Diff |
0003609: Kafka support as a load only node |
Affected Issues 0003609 |
|
| mod - symmetric-client/src/main/java/org/jumpmind/symmetric/ClientSymmetricEngine.java | Diff File | ||
| mod - symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java | Diff File | ||
| mod - symmetric-core/src/main/java/org/jumpmind/symmetric/load/DefaultDataLoaderFactory.java | Diff File | ||
| add - symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java | Diff File | ||
| mod - symmetric-db/src/main/java/org/jumpmind/db/platform/DatabaseNamesConstants.java | Diff File | ||
| mod - symmetric-db/src/main/java/org/jumpmind/db/platform/cassandra/CassandraSqlTemplate.java | Diff File | ||
| add - symmetric-db/src/main/java/org/jumpmind/db/platform/kafka/KafkaDdlBuilder.java | Diff File | ||
| add - symmetric-db/src/main/java/org/jumpmind/db/platform/kafka/KafkaDdlReader.java | Diff File | ||
| add - symmetric-db/src/main/java/org/jumpmind/db/platform/kafka/KafkaPlatform.java | Diff File | ||
| add - symmetric-db/src/main/java/org/jumpmind/db/platform/kafka/KafkaSqlTemplate.java | Diff File | ||
| add - symmetric-db/src/main/java/org/jumpmind/db/sql/AbstractJavaDriverSqlTemplate.java | Diff File | ||
| add - symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/KafkaWriter.java | Diff File | ||
| mod - symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymmetricEngineHolder.java | Diff File | ||
|
SymmetricDS: 3.9 4a10d0a7 2018-06-21 08:16:40 Details Diff |
0003609: Kafka support as a load only node |
Affected Issues 0003609 |
|
| mod - symmetric-assemble/common.gradle | Diff File | ||
| mod - symmetric-assemble/src/asciidoc/appendix/databases.ad | Diff File | ||
| add - symmetric-assemble/src/asciidoc/appendix/kafka.ad | Diff File | ||
| mod - symmetric-assemble/src/asciidoc/examples.ad | Diff File | ||
| add - symmetric-assemble/src/asciidoc/images/appendix/kafka-advanced-settings.png | Diff File | ||
| add - symmetric-assemble/src/asciidoc/images/appendix/kafka-node-setup.png | Diff File | ||
| mod - symmetric-core/src/main/java/org/jumpmind/symmetric/load/KafkaWriterFilter.java | Diff File | ||
| Date Modified | Username | Field | Change |
|---|---|---|---|
| 2018-06-20 13:30 | josh-a-hicks | New Issue | |
| 2018-06-20 13:30 | josh-a-hicks | Status | new => assigned |
| 2018-06-20 13:30 | josh-a-hicks | Assigned To | => josh-a-hicks |
| 2018-06-21 13:00 | josh-a-hicks | Changeset attached | => SymmetricDS 3.9 4a10d0a7 |
| 2018-06-21 13:00 | josh-a-hicks | Changeset attached | => SymmetricDS 3.9 ae87fc60 |
| 2018-06-21 18:52 | josh-a-hicks | Status | assigned => resolved |
| 2018-06-21 18:52 | josh-a-hicks | Resolution | open => fixed |
| 2018-06-21 18:52 | josh-a-hicks | Fixed in Version | => 3.9.9 |
| 2018-06-21 19:16 | admin | Status | resolved => closed |
| 2019-04-24 14:46 | elong | Relationship added | related to 0003015 |