Commit Graph

1090 Commits

Author SHA1 Message Date
Jiri Pechanec
eb7cc3f28e DBZ-537 Change OffsetCommitPolicy to use Duration in API 2018-02-09 15:19:48 +01:00
Jiri Pechanec
8c3daa387d DBZ-537 Move OffsetCommitPolicy to SPI 2018-02-09 15:19:48 +01:00
Jiri Pechanec
452f9af52d DBZ-537 Configurable offset commit strategy 2018-02-09 15:19:48 +01:00
Gunnar Morling
e8fa7b887e DBZ-588 Typo fix and additional method comment 2018-02-09 14:16:53 +01:00
Jiri Pechanec
2710094d11 DBZ-588 Defensively protecting CUD events themeselves 2018-02-09 11:03:16 +01:00
Jiri Pechanec
e4c9cf7191 DBZ-588 Changed message wording 2018-02-09 11:03:16 +01:00
Jiri Pechanec
16f4726a31 DBZ-588 Fail on inconsistent schema 2018-02-09 11:03:16 +01:00
Jiri Pechanec
b3b379a3a3 DBZ-594 Stop copy threads after initial sync is completed 2018-02-05 12:37:10 +01:00
Jiri Pechanec
6150955a47 DBZ-590 Detect non-available offset 2018-02-05 12:20:47 +01:00
Gunnar Morling
7b6db00db7 DBZ-593 JavaDoc 2018-02-02 13:16:43 +01:00
Gunnar Morling
712824e43f DBZ-593 Passing version explicitly from SourceInfos to base class instead of relying specific packaging structure 2018-02-02 13:16:43 +01:00
Jiri Pechanec
7ebee94169 DBZ-593 Add Debezium version to source in envelope 2018-02-02 13:16:43 +01:00
Gunnar Morling
3a281d1185 DBZ-595 Making sure resources are cleaned up when snapshotting fails;
* shutting down the snapshotting thread and the DB history producer client
  if the connector is stopped while trying to write to the history topic
* reducing the time that KafkaProducer#send() will block if Kafka isn't
  available; this will release the producer thread quicker in case the
  connector is stopped during snapshotting
* not returning from finally block (!) in case the TX is rolled back; This
  prevented the failed state to be set by the outer catch clause in execute()
2018-02-02 09:06:32 +01:00
Gunnar Morling
8821d89dfe DBZ-587 Making sure snapshot reader thread is removed 2018-02-01 10:04:20 +01:00
Jiri Pechanec
92740a3626 DBZ-587 Fix thread leak, thread names 2018-02-01 10:04:20 +01:00
Jiri Pechanec
9b592204ac DBZ-587 Centralize and unify thread management 2018-02-01 10:04:20 +01:00
Gunnar Morling
018a879d40 DBZ-583 Extracting a builder from ChainedReader, avoiding mutable state within its implementation 2018-01-30 08:59:41 +01:00
Jiri Pechanec
93cfb4f4cb DBZ-572 Transaction is completed also by XID event 2018-01-29 15:40:41 +01:00
Gunnar Morling
6089d6d051 DBZ-579 Using port 27017 in TestHelper as that's the port used by our Docker set-up 2018-01-29 15:24:16 +01:00
Jiri Pechanec
294a46eeef DBZ-579 Allow repeated running of MongoDB tests from IDE withou config 2018-01-29 15:24:16 +01:00
Jiri Pechanec
2c74dd74a3 DBZ-577 Numeric arrays correctly working 2018-01-29 15:14:11 +01:00
Jenkins user
04624341f5 [maven-release-plugin] prepare for next development iteration 2018-01-25 09:39:44 +00:00
Jenkins user
898f6884e1 [maven-release-plugin] prepare release v0.7.2 2018-01-25 09:39:44 +00:00
Jiri Pechanec
f38ecdba98 Changelog for 0.7.2 2018-01-25 10:35:03 +01:00
Gunnar Morling
8edcf9f3d8 DBZ-507 Making "wkb" optional in Point schema to keep compatability with previous version 2018-01-24 16:51:54 +01:00
Robert Coup
e3fbf165ed DBZ-507 Temporarily disabling geometry/geography array support in postgres until array support is improved.
Test tidyups.
2018-01-24 16:51:54 +01:00
Robert Coup
f9d90a482f DBZ-507 Expanding support for geometry types;
* Adding support for PostGIS geometry types
* Adding support for GEOMETRY, POLYGON and more in MySQL
* For all newly supported types, changes are represented using two new schema types Geometry and Geography, containing the WKB (binary geo data) ans srid (coord system identifier)
* The existing Point type also contains the new (optional) srid field
2018-01-24 16:51:49 +01:00
Jiri Pechanec
01577b40c3 DBZ-541 Only whitelisted tables are recorded in history 2018-01-24 14:43:57 +01:00
Gunnar Morling
ea4b366b7f DBZ-538 Capturing unparseable DDL for logging in one more place 2018-01-24 11:30:51 +01:00
Jiri Pechanec
cfdee13037 DBZ-568 Test wal2json as part of Travis build 2018-01-24 09:06:53 +01:00
Jiri Pechanec
5ff2cf4dd8 DBZ-558 Return correct array OID 2018-01-23 19:34:39 +01:00
Gunnar Morling
80e82edb37 DBZ-409 Adding Sairam Polavarapu to COPYRIGHT.txt 2018-01-23 14:47:49 +01:00
Gunnar Morling
6c0920c701 DBZ-409 Emitting null value for deletes 2018-01-23 14:41:39 +01:00
Gunnar Morling
707421e8e5 DBZ-409 Adding test for complex id type 2018-01-23 14:41:39 +01:00
Gunnar Morling
9fcf670df1 DBZ-409 Adding proper test for UnwrapFromMongoDbEnvelope;
* removing "_id" field
* using more sensible variable names
2018-01-23 14:41:39 +01:00
Gunnar Morling
808da37f48 DBZ-409 Indentation fixes 2018-01-23 14:41:39 +01:00
Gunnar Morling
b7f72bbe3a DBZ-409 Dependency clean-up 2018-01-23 14:41:39 +01:00
Sairam Polavarapu
e1cfa66862 DBZ-409 Added the testcase for UnwrapFromMongoDbEnvelope and also renamed the class names accordingly. 2018-01-23 14:41:39 +01:00
Gunnar Morling
1cfc8c3596 DBZ-409 Indentation fix 2018-01-23 14:41:39 +01:00
Gunnar Morling
d6dbf02f4c DBZ-409 Formatting of test and JSON file; removing unused JSON file 2018-01-23 14:41:39 +01:00
Sairam Polavarapu
8f268993ce DBZ-409 Adding SMT for converting MongoDB CDC messages into traditional flat format 2018-01-23 14:41:39 +01:00
Peter Goransson
7d78357087 DBZ-443 Adding db-history recovery mode: schema_only_recovery 2018-01-23 09:17:39 +01:00
Jiri Pechanec
fe16050cdb DBZ-521 SourceRecord is now associated with metadata 2018-01-19 21:18:55 +01:00
Gunnar Morling
6f6ce33958 DBZ-521 Misc. improvements and fixes;
* Actually assing last processed LSN to commit()
* passing LSN to commit() instead of entire SourceRecord
* Avoiding exception in case of wal2json batch with exactly one element
* Using "Lsn" instead of "LSN" in method names
* JavaDoc clarifications
2018-01-19 21:18:55 +01:00
Jiri Pechanec
0b5348339a DBZ-521 Record LSN for the last message committed to Connect 2018-01-19 21:18:55 +01:00
Jiri Pechanec
c3edf8ee9c DBZ-504 Type changes detected for constraints 2018-01-19 14:45:08 +01:00
Gunnar Morling
1bc9dec6f5 DBZ-555 Adding Denis Mikhaylov to COPYRIGHT.txt; formatting 2018-01-19 12:30:26 +01:00
Denis Mikhaylov
048f1323cd DBZ-555 Add missing config fields to EmbeddedEngine 2018-01-19 12:30:17 +01:00
Gunnar Morling
7a7d43c237 DBZ-516 Returning control also from BlockingReader 2018-01-18 14:13:58 +01:00
Gunnar Morling
0c4190c493 DBZ-516 Using Duration instead of long in a few more places 2018-01-18 14:13:58 +01:00