Commit Graph

1001 Commits

Author SHA1 Message Date
Jiri Pechanec
0b95df28d5 DBZ-2411 Use Scala 2.12 2020-08-11 09:20:53 +02:00
Jiri Pechanec
391d086529 DBZ-2411 Upgrade to Kafka 2.6.0 2020-08-11 09:20:53 +02:00
rkerner
cad6cf62d3 DBZ-2315 fix BIT VARYING handling in Postgres connector
* removed little endian padding for BIT types in JdbcValueConverters (only used for Postgres yet)
* removed legacy format handling fot BIT related types in JdbcValueConverters#convertBits which were leftovers from PR #1408
* removed unnecessary zero-ing of a newly created byte array to improve performance for huge byte arrays
* updated Postgres connector docs
2020-08-03 14:58:31 +02:00
Cory Harper
724fc7ac98 DBZ-2362 add configurable restart wait time 2020-07-30 18:08:26 +02:00
Jiri Pechanec
5fcb221993 DBZ-1491 Database connection provides default value 2020-07-24 09:07:09 +02:00
Jiri Pechanec
45a6f9bef1 DBZ-1491 Refactor after review 2020-07-24 09:07:09 +02:00
Grzegorz Kołakowski
825ffe3848 DBZ-1491 Add SqlServerDefaultValueConverter class 2020-07-24 09:07:07 +02:00
Grzegorz Kołakowski
234341a471 DBZ-1491 Parse temporal values using queries on database
* Add tests for altering column default value
 * Add end-to-end test
2020-07-24 09:06:30 +02:00
Grzegorz Kołakowski
a8ea5e2256 DBZ-1491 Extract default values from schema
The goal is to enrich schema metadata with column default value.
2020-07-24 09:05:58 +02:00
Gunnar Morling
3ebfbcefdb DBZ-2329 Moving isNewTransaction() to SQL Server implementation 2020-07-24 07:57:50 +02:00
Lukasz Korzeniowski
1ada5c4b23 DBZ-2329 Do not skip events after restart when stream is not monotonic 2020-07-21 14:21:29 +02:00
Jos Huiting
da97be7842 DBZ-2307 - Improve logging when primary keys are missing 2020-07-15 11:18:48 -04:00
Omar Al-Safi
4d2467ca20 DBZ-2302: Allow OffsetCommitPolicy to be initiated with Properties object 2020-07-09 08:38:26 +02:00
Randall Hauch
5860812a63
DBZ-2275 Updated default database history DML filter default to handle additional RDS statements;
* Added two more regular expressions to the default database history DML filter. These are intended to catch and filter out `INSERT into mysql.rds_monitor…` statements that RDS may write in the binlog
* Added a new unit test that checks that the regular expressions do catch some example statements
2020-06-25 20:57:49 +02:00
Jiri Pechanec
63a2f6a0ae DBZ-2255 Document JSON parsing in groovy-based SMTs 2020-06-25 11:08:59 +02:00
Jiri Pechanec
87d93d44fd DBZ-2221 Wait for keepalive thread initialization 2020-06-24 09:14:42 +02:00
Gunnar Morling
b80f064131 DBZ-2250 Allowing to use CloudEventsConverter with Avro via Apicurio 2020-06-22 14:41:10 +02:00
Gunnar Morling
f2d13238aa DBZ-2228 Using unique names for admin clients 2020-06-18 14:08:56 +02:00
Chris Cranford
ac0d9ede8a DBZ-2152 Fix test failure 2020-06-09 17:20:51 +02:00
Balázs Németh
0853940f3d
DBZ-2169 Fix for misuse of ConfigurationDefaults.RETURN_CONTROL_INTERVAL;
* Implemented Temporals.min()
* Fixed pollInterval calculation based on the documentation
2020-06-09 10:24:50 +02:00
Gunnar Morling
bfaadcf2dd DBZ-2149 Starting/stopping Kafka just once in KafkaDatabaseHistoryTest;
By using distinct topic names in the tests, the same Kafka instance can
be used for all test methods. This brings down execution time of this
test from ~40sec to ~8sec.
2020-06-09 10:15:47 +02:00
Chris Cranford
c3b36c2417 DBZ-2149 Log begin/end of schema recovery 2020-06-09 10:15:47 +02:00
Gunnar Morling
1fdad23087 Revert "DBZ-2166 Handling error condition where schema field can not be found in"
This reverts commit 283740f37e.
2020-06-08 20:12:50 +02:00
Dave Cumberland
4254e29667 DBZ-2152 Adding fix annotations to new tests 2020-06-08 13:57:35 -04:00
Dave Cumberland
a17e4cbad0 DBZ-2152 Adding another unit test with the key mapping definied 2020-06-08 13:57:35 -04:00
Dave Cumberland
223812def3 DBZ-2152 Updating the EventRouter to allow key types other than String 2020-06-08 13:57:35 -04:00
Fabian Aussems
283740f37e DBZ-2166 Handling error condition where schema field can not be found in
TableSchemaBuilder
2020-06-08 12:55:16 +02:00
Gunnar Morling
1b62036cf4 DBZ-2150 Awaiting coordinator shutdown in embedded engine 2020-06-08 10:26:37 +02:00
Gunnar Morling
c54e377dd2 DBZ-1814 Exporting Hex and Base64 representations as string 2020-06-05 12:13:29 +02:00
Gunnar Morling
023064eedb DBZ-1814 Renaming "raw" to "bytes"; also clarifying that this notion isn't Java-specific 2020-06-05 12:13:29 +02:00
Jeremy Finzel
5db614da21 DBZ-1814 added new binary handling mode option 2020-06-05 12:13:29 +02:00
Jiri Pechanec
86dac40dae DBZ-2140 Internal configs must not be validated 2020-06-04 11:47:26 +02:00
Kewei Shang
a963e89704 DBZ-2136 Update ChangeEventQueue Javadoc by fixing typo 2020-06-02 09:38:12 +02:00
Jiri Pechanec
8e7f3d14ca DBZ-1312 Omit constatnt db name in column and key mappers 2020-06-01 12:43:45 +02:00
Jiri Pechanec
20b45f84f3 DBZ-1657 Remove duplicate option definitions 2020-05-22 12:07:29 +02:00
Gunnar Morling
ed838fb2d4 DBZ-2089 Typo fix 2020-05-22 08:36:57 +02:00
Jiri Pechanec
84851297cb DBZ-2089 JMX no longer mandatory 2020-05-22 08:36:57 +02:00
Jiri Pechanec
e676d715c3 DBZ-2085 Apply custom converters to default values 2020-05-18 17:27:59 +02:00
Jiri Pechanec
c85546d611 DBZ-2074 Expose topic and headers in scripting SMTs 2020-05-15 11:13:07 +02:00
Gunnar Morling
0b42c8d8c2 DBZ-2024 Adding topic.regex option to routing and filtering SMTs 2020-05-14 08:41:40 +02:00
Jiri Pechanec
c4f975bd0a DBZ-2061 Handle change of default value 2020-05-14 08:31:27 +02:00
Gunnar Morling
4f020ca6cf DBZ-1828 Removing deprecated SMT options 2020-05-13 21:36:12 +02:00
Chris Cranford
f449550b2d DBZ-2068 Skip tests incompatible with Kafka 1.x 2020-05-13 08:22:07 +02:00
Aaron Brady
8b42016f63 DBZ-2034 Make ByLogicalTableRouter SMT unique key enforcement optional 2020-05-08 13:56:18 -04:00
Chris Cranford
c6ba581848 DBZ-2014 Suggested changes 2020-05-05 22:13:25 +02:00
Chris Cranford
cd43c4880f DBZ-2014 Do not include outbox eventType field by default 2020-05-05 22:13:25 +02:00
Chris Cranford
3c9ad5699b DBZ-2036 Change logging from warn to debug 2020-05-05 21:58:56 +02:00
Chris Cranford
81c3a808da DBZ-1963 Suggested changes 2020-05-05 08:45:58 +02:00
Chris Cranford
a1cb06299c DBZ-1963 Emit outbox events with value schema names 2020-05-05 08:45:58 +02:00
Jiri Pechanec
1b3fba4b8c DBZ-1904 Add drop table support 2020-05-04 12:31:05 +02:00
Jiri Pechanec
b9fa634968 DBZ-1904 Rename queueing methods 2020-05-04 12:31:05 +02:00
Jiri Pechanec
7f23d74d90 DBZ-1904 Add config param into a group 2020-05-04 12:31:05 +02:00
Jiri Pechanec
e350d74b17 DBZ-1904 Public facing schema history topic 2020-05-04 12:31:05 +02:00
Gunnar Morling
2310d6c792 DBZ-1969 Fixing incorrect assertion and utility which concealed this 2020-04-29 13:06:43 -04:00
Braden Groom
0b429ce880 DBZ-1969 Add support for Postgres enum arrays 2020-04-29 13:06:43 -04:00
Chris Cranford
230ddaebdc DBZ-1953 Generalized SkipWhenDatabaseVersion functionality 2020-04-29 12:27:38 +02:00
Gunnar Morling
5fb3b7f2a1 DBZ-2027 Removing some unused code 2020-04-29 09:56:59 +02:00
Gunnar Morling
e9632c2227 DBZ-1972 Formatting 2020-04-27 17:54:35 +02:00
Gunnar Morling
8b2448440b Revert "DBZ-2025 Reduce capture job poll interval"
This reverts commit 131063fb2be38f865019e5dcff74b6d78299f6d2; it prove
unstable on CI.
2020-04-27 16:38:01 +02:00
Jiri Pechanec
131063fb2b DBZ-2025 Reduce capture job poll interval 2020-04-27 13:56:29 +02:00
JanHendrikDolling
33d83731af DBZ-1972 move static Filed methods as static Filed constant to RelationalDatabaseConnectorConfig instead. 2020-04-27 12:31:19 +02:00
Gunnar Morling
f9bfe26754 DBZ-1753 Typo fix 2020-04-27 11:27:36 +02:00
Chris Cranford
f974f9f4ab DBZ-1753 Refactor common code between SQL Server and DB2 2020-04-24 13:45:06 -04:00
Jiri Pechanec
7e37237b52 DBZ-2000 Change expression param name; add docs 2020-04-24 15:44:52 +02:00
Gunnar Morling
90d2e24788 DBZ-2000 Misc. clean-up 2020-04-24 15:44:52 +02:00
Jiri Pechanec
3ceb6ced3e DBZ-2000 Content based router SMT 2020-04-24 15:44:52 +02:00
Gunnar Morling
03ce403972 DBZ-1750 Separating config definition editor and immutable config definitions 2020-04-24 15:35:28 +02:00
Jiri Pechanec
37f0dbcaf8 DBZ-1750 Limit access to parent defs; dont share the parent defs 2020-04-24 15:35:28 +02:00
Jiri Pechanec
0d8d6a41c5 DBZ-1750 Validate Kafka params only for Kafka history 2020-04-24 15:35:28 +02:00
Jiri Pechanec
af90507fa6 DBZ-1750 Centralize shared config definitions 2020-04-24 15:35:28 +02:00
Jiri Pechanec
412f288e88 DBZ-1923 Detect lost database history 2020-04-24 10:22:06 +02:00
Chris Cranford
24abc23f66 DBZ-2007 Upgrade Formatter and Impsort plugins 2020-04-23 11:21:06 +02:00
Gunnar Morling
2d0da37c03 DBZ-1993 Wrapping structs for simpler references in filter SMT;
Exposing as ProxyObject allows for simple property-style access. We also can prevent write access that way.
2020-04-23 08:33:30 +02:00
Gunnar Morling
0998fc533a DBZ-1895 Completing implementation;
* Restoring original derserializers; excluding skipped events in event handlers
* Adding test
2020-04-22 15:04:36 +02:00
Gunnar Morling
dae655c78b DBZ-2006 Misc. fixes to MongoDB connector docs 2020-04-22 11:42:21 +02:00
Gunnar Morling
1a5dd5db98 DBZ-1886 Misc. clean-up 2020-04-20 17:46:03 +02:00
Ivan Klass
75f19239d1 DBZ-1886 Introduce separate storageExists() method to support manual topic creation 2020-04-20 17:46:03 +02:00
Gunnar Morling
bc762f2989 DBZ-1962 Adding option descriptions 2020-04-17 15:24:42 +02:00
Jos Huiting
33fe631674 DBZ-1962 Fix PR feedback 2020-04-17 15:24:42 +02:00
Jos Huiting
8ba21a98ef DBZ-1962 Introduce column.whitelist for the Postgres connector 2020-04-17 15:24:42 +02:00
Gunnar Morling
786aab37d9 DBZ-1782 JavaDoc improvements;
As per Chris's suggestions.

Co-Authored-By: Chris Cranford <ccranfor@redhat.com>
2020-04-15 17:52:35 +02:00
Gunnar Morling
0673aba092 DBZ-1782 Inverting filtering logic, so to be consistent with Stream#filter() and other similar APIs 2020-04-15 17:52:35 +02:00
Gunnar Morling
0775bb1f4f DBZ-1782 Allowing any JSR 223 implementation for filtering SMT 2020-04-15 17:52:35 +02:00
Gunnar Morling
905629973e DBZ-1968 Removing SMTs deprecated in 0.10 2020-04-15 15:11:32 +02:00
Chris Cranford
e87bfefdf7 DBZ-1859 Renamed MetadataEvent to ConnectorEvent 2020-04-15 08:04:23 +02:00
Chris Cranford
57af80afd5 DBZ-1859 Enhance MongoDB connector metrics 2020-04-15 08:04:23 +02:00
Gunnar Morling
680f1f73af DBZ-1782 Misc. fixes 2020-04-09 18:09:56 +02:00
Jiri Pechanec
08d2c9679f DBZ-1782 Support for Graal JS 2020-04-09 18:09:56 +02:00
Jiri Pechanec
53c8603148 DBZ-1782 Use JSR223 API 2020-04-09 18:09:56 +02:00
Jiri Pechanec
112aeb9d21 DBZ-1782 Groovy based filtering SMT 2020-04-09 18:09:56 +02:00
JanHendrikDolling
1e19270981 DBZ-1692 Added support for hash based column masking mode for string values 2020-04-08 21:21:42 +02:00
Jiri Pechanec
384f62463c DBZ-1905 Stop checking thread upong completion 2020-04-08 12:18:32 +02:00
Jiri Pechanec
318d1d3cc7 DBZ-1905 Make thread-naming params internal and optional 2020-04-08 12:18:32 +02:00
Jiri Pechanec
e81aec0ed1 DBZ-1905 Validate database history topic 2020-04-08 12:18:32 +02:00
Chris Cranford
65c8564d66 DBZ-1925 Introduced SkipWhenKafkaVersion annotation support 2020-04-07 09:01:20 +02:00
Jiri Pechanec
6338309cea DBZ-1918 Initialize Metronome when needed 2020-04-01 09:48:24 +02:00
Gunnar Morling
89bb6eba6c DBZ-1531 Misc. clean-up;
* Removing obsolete default impl
* Completing test
* Documention fixes
2020-03-25 12:33:38 +01:00
rk3rn3r
7f36b3c08f DBZ-1531 added headers for primary key update events to reference the original key 2020-03-25 12:33:38 +01:00
rk3rn3r
6310e00675 DBZ-1531 added headers for primary key update events to reference the original key 2020-03-25 12:33:38 +01:00
rk3rn3r
fbd8b94e94 DBZ-1531 added headers for primary key update events to reference the original key 2020-03-25 12:33:38 +01:00
Jiri Pechanec
32b6a8cb3c DBZ-1889 Use parker 2020-03-23 13:56:29 +01:00
Jiri Pechanec
d2bdcd1ab3 DBZ-1889 Prevent Connect throttling while connection is down 2020-03-23 13:56:29 +01:00
Jiri Pechanec
224f97e380 DBZ-1857 Support for autorestart for embedded engine 2020-03-23 13:56:29 +01:00
Gunnar Morling
bbaf32fe82 DBZ-1815 Misc. clean-up 2020-03-18 10:27:22 +01:00
trolison
8784b41e22 DBZ-1815 Ading DatabaseHeartbeatImpl to allow for making queries to the DB when a heartbeat happens;
* Minor refactor to make DatabaseHeartbeatImpl usable
* Added integration test to verify heartbeat.action.query is being executed properly
2020-03-18 10:27:22 +01:00
Gunnar Morling
e4a1272dff DBZ-1876 Adding comment 2020-03-13 16:21:33 +01:00
Jiri Pechanec
6e482de3d5 DBZ-1876 Process headers with tombstone 2020-03-13 16:21:33 +01:00
Gunnar Morling
449154beaa DBZ-1863 Centralizing coordinator shutdown 2020-03-12 11:28:08 +01:00
Gunnar Morling
da1f7efb21 DBZ-1723 Formatting 2020-03-11 13:57:23 +01:00
Gunnar Morling
7e55315f78 DBZ-1723 Encapsulating retriable determination in error handler 2020-03-11 13:57:23 +01:00
Gunnar Morling
c51a5fb597 DBZ-1723 Restarting after connection losses in Postgres 2020-03-11 13:57:23 +01:00
Gunnar Morling
63404e14ca DBZ-1723 Infrastructure for enabling restarts after retriable errors 2020-03-11 13:57:23 +01:00
Gunnar Morling
3437da00d7 DBZ-1723 Simplifying shutdown handling;
doStop() is already called from stop(), no need to do it again via the error handler.
2020-03-11 13:57:23 +01:00
Gunnar Morling
c156d30048 DBZ-1723 Centralizing stopping() logic in BaseSourceTask 2020-03-11 13:57:23 +01:00
Gunnar Morling
8ce69dc597 DBZ-1723 Encapsulating common poll() and stop() logic in BaseSourceTask 2020-03-11 13:57:23 +01:00
Gunnar Morling
6318cf0f2b DBZ-1831 Pulling up connector option retrieval to CommonConnectorConfig;
* Expanding test
* Adding Sayed to COPYRIGHT.txt
2020-03-11 12:43:25 +01:00
Sayed Mohammad Hossein Torabi
63a462dbc0 DBZ-1831 Support MongoDB Oplog operations as config 2020-03-11 12:43:25 +01:00
Jiri Pechanec
082761effc DBZ-1856 Deprecation process is not necessary 2020-03-11 12:02:07 +01:00
Chris Cranford
dc1d526caa DBZ-1726 Fix test failure for relational connectors 2020-03-11 10:15:00 +01:00
Chris Cranford
3a4788cc33 DBZ-1726 Introduced AbstractSnapshotChangeEventSource and refactor implementations 2020-03-11 10:15:00 +01:00
Chris Cranford
38cf4ceae1 DBZ-1726 Introduce DataCollectionId#identifier() 2020-03-11 10:15:00 +01:00
Chris Cranford
4e27c90028 DBZ-1726 Move MongoDB connector to common framework 2020-03-11 10:15:00 +01:00
Fabio Cantarini
62b46ae596 DBZ-1830 Enhancement to datatype.propagate.source.type connector property
Add support for matching db and table name
Amend documentation accordingly
2020-03-10 14:58:16 +01:00
Fabio Cantarini
61cc791d32 DBZ-1830 Add support for new connector property datatype.propagate.source.type 2020-03-10 14:58:16 +01:00
Jiri Pechanec
0f11f7e6de DBZ-1834 Support separately quoted schema and table 2020-03-03 10:56:19 +01:00
Jiri Pechanec
c201578d29 DBZ-1834 Support dots in table names 2020-03-03 10:56:19 +01:00
Jiri Pechanec
7d525d4baa DBZ-1134 Fix tests for new API 2020-02-28 21:58:39 +01:00
Gunnar Morling
0f6d2c54fc DBZ-1134 Avoiding concrete class in SPI by introducing receiver parameter 2020-02-28 21:58:39 +01:00
Gunnar Morling
e7fd7acab8 DBZ-1134 Making converter registry thread-safe; misc. clean-up 2020-02-28 21:58:39 +01:00
Jiri Pechanec
096d13f266 DBZ-1134 Use OptionalInts 2020-02-28 21:58:39 +01:00
Jiri Pechanec
d13e48cc55 DBZ-1134 Make converted field type parametrized 2020-02-28 21:58:39 +01:00
Jiri Pechanec
06e1eca085 DBZ-1134 Support for user provided converters 2020-02-28 21:58:39 +01:00
Jiri Pechanec
06049a5e9d DBZ-1826 Rename error handling config field 2020-02-26 15:49:26 +01:00
Jiri Pechanec
91f292a1f2 DBZ-1825 Keep keys for non-matching table 2020-02-26 15:03:03 +01:00
Jiri Pechanec
ae6ee3d458 DBZ-234 Place Incubating into a unique package 2020-02-25 15:31:10 +01:00
Jiri Pechanec
f66fe17989 DBZ-234 Incubating annotation moved to API 2020-02-25 15:31:10 +01:00
Jiri Pechanec
436615934d DBZ-1760 Align code and docs 2020-02-25 10:43:11 +01:00
Jiri Pechanec
2b6e50daff DBZ-1760 Allow skipping of invalid events 2020-02-25 10:43:11 +01:00
Gunnar Morling
5650276ba9 DBZ-1805 Removing unused private method parameter 2020-02-18 10:29:45 +01:00
Jiri Pechanec
566efd6a3f DBZ-1775 Filter out rds_monitor DML events 2020-02-14 14:26:02 +01:00
Gunnar Morling
1e51f112b2 DBZ-1772 Trimming values for add.source.fields option 2020-02-14 12:51:58 +01:00
Gunnar Morling
61c4f834a6 DBZ-1452 Misc. fixes and refactoring;
* Adding support for "transaction" struct
* Documentation updates
* Only one "_" as separator between struct and field name
2020-02-12 14:03:19 -05:00
daanroosen-DS
49bbec319b DBZ-1452 Adding add.fields and add.headers options to flattening SMT 2020-02-12 14:03:19 -05:00
Jiri Pechanec
a998db9caa DBZ-1767 Support field sanitization for MongoDB unwrap 2020-02-12 18:49:32 +01:00
Gunnar Morling
92fa6039ab DBZ-1766 Adding Melissa Winstanley to COPYRIGHT.txt 2020-02-12 15:44:45 +01:00
Gunnar Morling
dd5c2b8be9 DBZ-1766 Unifying handling of offset commits 2020-02-12 15:44:45 +01:00
Matthias Wessendorf
bff73e71d0
DBZ-1784 Use "application/avro" as data content type in CloudEvents
Signed-off-by: Matthias Wessendorf <mwessend@redhat.com>
2020-02-12 14:26:25 +01:00
Jiri Pechanec
77f9a61b95 DBZ-1751 Centralize envelope schema naming 2020-02-04 20:37:19 +01:00
Gunnar Morling
b66f314b3c DBZ-1052 Misc. clean-up
* Doc updates
* Changed static method to instance
2020-02-03 09:29:10 +01:00
Jiri Pechanec
ba10a229b6 DBZ-1052 CE support for tx metadata in data messages 2020-02-03 09:29:10 +01:00
Jiri Pechanec
0e671d6167 DBZ-1052 Add counts per table to END 2020-02-03 09:29:10 +01:00
Jiri Pechanec
60056b0a94 DBZ-1052 Transaction block moved to envelope 2020-02-03 09:29:10 +01:00
Jiri Pechanec
4867c8a298 DBZ-1052 Change TX topic name 2020-02-03 09:29:10 +01:00
Jiri Pechanec
5749acda7e DBZ-1052 Remove unused fields; added JavaDoc 2020-02-03 09:29:10 +01:00
Jiri Pechanec
c0557b325b DBZ-1052 Skip CE for transaction struct 2020-02-03 09:29:10 +01:00
Jiri Pechanec
cd6a1f942d DBZ-1052 Transaction metadata for Postgres/pgoutput 2020-02-03 09:29:10 +01:00
Jiri Pechanec
b0eb571f9f DBZ-1052 Transaction metadata for SQL Server 2020-02-03 09:29:10 +01:00
Jiri Pechanec
6f7b8d1707 DBZ-1748 Mask JDBC passwords from log messages 2020-01-31 17:26:59 +01:00
Gunnar Morling
2d337133ae DBZ-1715 Docs clarification; adding Jos to authors list 2020-01-17 14:52:15 +01:00
Jos Huiting
1cd4d4bf19 Add field-based topic routing to Debezium ExtractRecordState 2020-01-17 14:43:03 +01:00
Gunnar Morling
8ca6174d98 DBZ-1292 Applying suggestions from code review
Co-Authored-By: Chris Cranford <ccranfor@redhat.com>
2020-01-16 08:02:51 +01:00
Gunnar Morling
8c33a4e147 DBZ-1292 Catering for the differences in data schema;
* MongoDB doesn't have "before", but "patch"
* Also removing some redundancies and making RecordParser immutable
* Reducing log verbosity during tests
2020-01-16 08:01:56 +01:00
Gunnar Morling
8531adbefd DBZ-1292 Formatting 2020-01-16 08:00:45 +01:00
Gunnar Morling
2ba1d615fb DBZ-1292 Distinct names for data and envelope schema for Avro/Avro 2020-01-16 08:00:45 +01:00
Gunnar Morling
8591dd669b DBZ-1292 Avoiding usage of reflection 2020-01-16 08:00:45 +01:00
Gunnar Morling
7c18a6d8d5 DBZ-1292 Removing static state in CloudEventsConverterTest 2020-01-16 08:00:45 +01:00
Gunnar Morling
366382ddad DBZ-1292 Refactoring of options;
* Avoiding hard dependency to Avro
* Passing through all options from JSON and Avro converters by means of "json." and "avro." sub-namespaces
2020-01-16 08:00:45 +01:00
Gunnar Morling
12e43a89f4 DBZ-1292 Always adding "before" and "after" 2020-01-16 08:00:45 +01:00
Gunnar Morling
a861dae432 DBZ-1292 Clean-up around data schema URI 2020-01-16 08:00:45 +01:00
Gunnar Morling
1a18bdbc81 DBZ-1292 Misc. refactorings;
* Protecting against Avro as CE format and JSON as data format
* Reducing mutability
* Single Avro client
2020-01-16 08:00:45 +01:00
Gunnar Morling
4e4800cb56 DBZ-1292 Some clean-up in CloudEventsMaker;
* Avoiding non-final static fields
* Removing unused methods
* Reducing visibility
2020-01-16 08:00:45 +01:00
Gunnar Morling
fe8c5fe27d DBZ-1292 Adding schema URI in case of Avro 2020-01-16 08:00:45 +01:00
Gunnar Morling
a25d148a82 DBZ-1292 Adding logical name to CE source attribute value 2020-01-16 08:00:45 +01:00
Gunnar Morling
342a448053 DBZ-1292 Using "iodebezium" prefix for extension attributes;
Simplifying implementation a bit.
2020-01-16 08:00:45 +01:00
Gunnar Morling
390c8f8090 DBZ-1292 Wrapping up work on schema and value conversion;
* There were a few attributes missing in the schema of the CE event
* Conversion of extension attributes now correctly handles optional attributes
* Removed guards against missing and duplicate fields, as the only caller is this class itself, so it seems superfluous.
2020-01-16 08:00:45 +01:00
GraySmog
de2655a89e DBZ-1292 promoting op, ts_ms and sub-fields in source to extension attributes 2020-01-16 08:00:45 +01:00
GraySmog
d0e4b3c0af DBZ-1292 Delete data.schema.registry.url config option 2020-01-16 08:00:45 +01:00
GraySmog
8b7c67cbdd DBZ-1292 Using formatted timestamp for CE time field 2020-01-16 08:00:45 +01:00
Gunnar Morling
87ffe0c44e DBZ-1292 Representing data as JSON struct instead of binary 2020-01-16 08:00:45 +01:00
Gunnar Morling
6356784cee DBZ-1292 dataschema value should not be empty or null if key is present;
* CloudEvents spec version is 1.0 now
2020-01-16 08:00:45 +01:00
GraySmog
915c8cafd9 DBZ-1292 CloudEvents converter for JSON and Avro format 2020-01-16 08:00:45 +01:00
Gunnar Morling
07e89de91d DBZ-1707 Ensuring correct Kafka record timestamp for outbox events;
Depending on the width of the configured TIMESTAMP column, a microsecond or nanosecond timestamp could have been returned before, whereas this should always be milliseconds.
2020-01-15 07:32:55 +01:00
Chris Cranford
4a27746dad DBZ-1703 Fix typo after renaming configuration option 2020-01-14 09:24:53 +01:00
Chris Cranford
4fa0f22ac7 DBZ-1703 Add option to JSON SerDes for ignoring unknown properties 2020-01-14 09:24:53 +01:00
liulangwa
6028d78e76 DBZ-1688 Fix SQLserver type time(4)...time(7) lost nanoseconds 2020-01-02 12:26:28 +01:00
Jiri Pechanec
761e7440cc DBZ-1670 Rename Serdes to DebeziumSerdes 2019-12-16 15:05:43 +01:00
Cobolbaby
f199988609 DBZ-1642 commit() method in JdbcConnection compatible with non autocommit 2019-12-13 10:34:52 +01:00
Cobolbaby
641e24b483 DBZ-1642 Create method called commit() in JdbcConnection class 2019-12-13 10:34:52 +01:00
Chris Cranford
19fd8dd1d9 DBZ-1413 Resolve column length/scale when reading table column metadata from TypeRegistry 2019-12-10 10:09:35 +01:00
Chris Cranford
365eb0d76e DBZ-1413 Suggested Javadoc changes, added/fix tests, changed how Column native/jdbc type resolution happens 2019-12-10 10:09:35 +01:00
Chris Cranford
4bce11f92a DBZ-1413 Remove some System.out madness 2019-12-10 10:09:35 +01:00
Chris Cranford
547ba8e0db DBZ-1413 Align domain type support across all 3 decoders 2019-12-10 10:09:35 +01:00
Gunnar Morling
68e7b7a0bb DBZ-1533 Documentation update 2019-12-10 10:07:55 +01:00
Jiri Pechanec
1805d1d73b DBZ-1533 Added documentation 2019-12-10 10:07:55 +01:00
Jiri Pechanec
7e4ea91a10 DBZ-1533 Allow keeping envelope 2019-12-10 10:07:55 +01:00
Jiri Pechanec
8a64ce71d2 DBZ-1533 JSON payload serde 2019-12-10 10:07:55 +01:00
Gurnaaz Randhawa
4f60fac367 DBZ-1650 Changing sorting into a HashSet to a LinkedHashSet 2019-12-05 09:50:25 +01:00
Thomas Deblock
17e44d4c0c DBZ-1648 outbox EventRouter remove topic toLowerCase
- kafka topics names are case sensitive. We should not perform
  a toLowerCase on the topic name. It can cause some issue if
  topic name have a upper case
2019-12-04 21:39:25 +01:00
Ivan San Jose
cc8dd160f5 DBZ-1617 Blacklisted columns are not being filtered out when generating a Kafka message from a CDC event 2019-11-25 13:23:03 +01:00
Brandon Brown
a0f7f6ec6b DBZ-1402 Support for JDK 11 2019-11-25 11:53:19 +01:00
Jiri Pechanec
a56ab78b3f DBZ-825 Unify decimal upscaling 2019-11-20 18:23:55 +01:00
pan3793
33384098fd DBZ-1621 Remove useless null check 2019-11-19 07:35:03 +01:00
pan3793
91f0c2a520 DBZ-1621 Fix IoUtil.createDirectory parameter removeExistingContent is not take effect 2019-11-19 07:35:03 +01:00
pan3793
89fde5ce06 DBZ-1622 Fix VariableLatch.create parameter initialValue is not take effect 2019-11-19 07:33:52 +01:00
David Feinblum
2b9fbcd5f6 DBZ-1519 Avoid erroneously logging there are no monitored tables 2019-11-14 05:44:37 +01:00
Jiri Pechanec
2b9536f24d DBZ-1607 use Instant for envelope timestamps 2019-11-12 16:36:11 -05:00
Gunnar Morling
da2b6c2c78 DBZ-1555 JavaDoc fix; formatting 2019-11-08 15:09:46 +01:00
Luis Garcés-Erice
0198bceffa DBZ-1555 Enabling configuration of table parse mode to support DB2 2019-11-08 15:07:25 +01:00
Gunnar Morling
2c86b1c84f DBZ-1604 Documentation update 2019-11-08 10:23:23 +01:00
Yang Yang
884def88d7 DBZ-1604 Added a new converter to enable byte[] payload 2019-11-08 10:19:21 +01:00
Jiri Pechanec
d1ee65d1b2 DBZ-1569 Don't compute index statistics 2019-11-06 15:43:21 +01:00
Jiri Pechanec
c179076710 DBZ-1592 Generate heartbeats for filtred events 2019-11-05 14:54:56 -05:00
Chris Cranford
f97be3272c DBZ-1590 Fix LogInterceptor to be thread-safe 2019-11-04 16:23:43 -05:00
Gunnar Morling
2c569977d7 DBZ-1392 Applying formatter;
* Keeping indentation formatting for JSON


Co-authored-by: Gunnar Morling <gunnar.morling@googlemail.com>
Co-authored-by: Chris Cranford <chris@hibernate.org>
2019-11-01 13:20:43 +02:00
Mike Graham
13c6c67a1d fix spelling error in exception message 2019-10-24 22:00:16 +02:00
Gunnar Morling
e06d25dd92 DBZ-1336 Moving Ltree type to PG connector module 2019-10-21 12:17:08 +02:00
Mincong HUANG
1e3eb8c840 DBZ-1336 Support Postgres LTREE columns 2019-10-21 12:10:46 +02:00
Jiri Pechanec
a92b93182e DBZ-1560 Removed dropped PK from the list 2019-10-20 22:13:02 +02:00
Gunnar Morling
4ea85d7fd3 DBZ-1565 Raise warning about growing WAL backlog 2019-10-18 13:53:53 +03:00
Grant Cooksey
18ca6ec72e DBZ-1546 Comma-separated regular expressions remove whitespace.
The table whitespace parameter should remove whitespace between regular expressions
since tables cannot start with whitespace characters.
2019-10-17 10:13:44 +03:00
Jiri Pechanec
6d8412e5de DBZ-1401 Support for pgoutput 2019-10-10 09:37:52 +02:00
Jiri Pechanec
7c4203cf60 DBZ-1401 Handle tables without explicit PK 2019-10-10 09:37:52 +02:00
Jiri Pechanec
cf7eccb152 DBZ-1498 Docs added; microseconds changed to numeric; nanos supported 2019-10-09 12:14:35 +02:00
Jiri Pechanec
20363f24bb DBZ-1498 Support for precise interval value 2019-10-09 12:14:35 +02:00
Jiri Pechanec
74fd88afca DBZ-1513 Improve start logging 2019-10-07 18:38:35 +02:00
Jiri Pechanec
2c4cb83259 DBZ-1513 Centralize handling of non-data messages in SMT 2019-10-07 18:38:35 +02:00
Gunnar Morling
92885ebe99 DBZ-1392 Removing trailing whitespace from Java files 2019-10-07 12:11:43 +03:00
Gunnar Morling
8d6f5409b1 DBZ-1392 Moving static imports up and applying this to all files 2019-10-07 12:11:43 +03:00
Chris Cranford
3594ff639a DBZ-1341 Rebased against master and applied necessary checkstyle fixes 2019-10-03 19:44:43 +02:00
Chris Cranford
ca5517746a DBZ-1341 Checkstyle flag missing whitespace 2019-10-03 19:44:43 +02:00
Chris Cranford
7442670692 DBZ-1355 Fix checkstyle problems detected after upgrade to 8.19 2019-10-03 19:44:43 +02:00
Chris Cranford
5ac2318d84 DBZ-1391 Do not allow code after closing brace (#1065)
* DBZ-1391 Do not allow code after closing brace
2019-10-02 20:44:40 +02:00
Jiri Pechanec
f868cb87c0 DBZ-1280 Lock timeout for SQL Server 2019-10-02 10:34:25 +02:00
pushpavanthar
891c8b90f4 DBZ-1492 - MySQL Connector Fails while parsing AWS RDS internal events 2019-10-02 10:31:09 +02:00
Gunnar Morling
d94b37c693 DBZ-1507 Misc. clean-up;
* Removing unused Table methods
* Re-using primaryKeyColumnNames() instead of custom predicate
2019-10-02 10:25:37 +02:00
Chris Cranford
d906096820 DBZ-1507 Ensure message keys have correct field order 2019-10-02 10:25:37 +02:00
Jiri Pechanec
410662c4aa DBZ-1517 Skip unknow records while operation header is used 2019-09-30 20:25:44 +02:00
Gunnar Morling
2fba51863e DBZ-1015 Unifying the retrieval of custom key mappers 2019-09-26 10:14:48 +02:00
Guillaume Rosauro
1405889bef DBZ-1015-allow-user-to-customize-key 2019-09-26 10:14:21 +02:00
Gunnar Morling
236bae4265 DBZ-1508 Avoiding assertion based on platform-specific line endings 2019-09-26 09:25:24 +02:00
Gunnar Morling
442408be02 DBZ-1497 Using int64 for INTERVAL microseconds mapping 2019-09-25 11:21:40 +03:00
Chris Cranford
b20e689b2c DBZ-1495 Avoid NPE by throwing more meaningful error messages 2019-09-25 08:08:16 +03:00
Jiri Pechanec
8f308746d3 DBZ-1438 Interrupt only after interrupt affected operations 2019-09-24 12:51:48 +02:00
jerrinot
3064a4af06 DBZ-1438 Fix InterruptedException handling
It appears there is an intent to restore the interruption flag
when catching InterruptedException. However the old code was just
checking the current state of the flag instead of raising it.
2019-09-24 12:51:48 +02:00
Gunnar Morling
9de7c25d60 DBZ-1405 Misc adjustments;
* Adding test
* Removing remaining double variables
2019-09-24 12:08:55 +02:00
Bingqin Zhou
d6353dd519 DBZ-1405 Add NanoDuration. 2019-09-24 12:08:55 +02:00
Gunnar Morling
c5d0b18ea3 DBZ-1044 "AVRO" -> "Avro", as it's not an abbreviation 2019-09-23 12:21:54 +02:00
Chris Cranford
074cbf01a3 DBZ-1044 Checkstyle fix: remove unused import 2019-09-20 07:40:23 +03:00
Chris Cranford
6dc37fc8f6 DBZ-1044 Fix broken test caused by previous commit 2019-09-20 07:40:23 +03:00
Chris Cranford
910d00f6a2 DBZ-1044 Fixed documentation typo, added tests, adjusted FieldNameSelector 2019-09-20 07:40:23 +03:00