Chris Cranford
e2c74111ad
DBZ-1234 Removed deprecated configuration options
2019-05-22 10:19:05 +02:00
Gunnar Morling
1ed8615434
DBZ-1234 Removing deprecated "drop.deletes" SMT option
2019-05-21 14:11:32 +02:00
Jiri Pechanec
a8e7104f18
DBZ-1209 Remove events skipped metric form common metrics
2019-05-21 10:26:22 +02:00
Jiri Pechanec
547ac819df
DBZ-1257 Fixed typo
2019-05-21 10:11:57 +02:00
Jiri Pechanec
8c376d1795
DBZ-1257 Validate data against schema
2019-05-21 10:11:57 +02:00
Gunnar Morling
4751b266f3
DBZ-1164 Misc. improvements;
...
* Moving stringToDuration() for the sake of re-use and testability
* Making pattern and durations constants
2019-05-21 09:38:23 +02:00
Jenkins user
7748be6056
[maven-release-plugin] prepare for next development iteration
2019-05-02 16:04:56 +00:00
Jenkins user
5af083b86e
[maven-release-plugin] prepare release v0.9.5.Final
2019-05-02 16:04:55 +00:00
Jiri Pechanec
b53f456912
DBZ-1245 Heartbeat only when offsets ready
2019-05-02 08:22:28 +02:00
Chris Cranford
c6aa02f813
DBZ-1226 Add support for enum/set values that contain commas or escaped characters.
2019-05-01 21:17:42 +02:00
Gunnar Morling
a84230447e
DBZ-1247 Making defaultSnapshotFetchSize() abstract
2019-04-30 09:57:11 +02:00
jchipmunk
72b06366fe
Removing extra initialisation of "config" variable in PG config
2019-04-30 09:57:11 +02:00
jchipmunk
9fe033ce24
DBZ-1247 Specifying default snapshot fetch size for each connector config
2019-04-30 09:57:11 +02:00
jchipmunk
a5cc83c0d1
DBZ-1247 Adding property to specify snapshot fetch size
2019-04-30 09:57:11 +02:00
krizhan
70c564b4c2
DBZ-212 Moved SERVER_NAME to RelationalDatabaseConnectorConfig
2019-04-23 12:29:44 +02:00
Jenkins user
cefc5ccfb9
[maven-release-plugin] prepare for next development iteration
2019-04-11 12:07:16 +00:00
Jenkins user
fc3026adc3
[maven-release-plugin] prepare release v0.9.4.Final
2019-04-11 12:07:15 +00:00
Steviep
94f71ea96e
DBZ-1206 Adding new connector metric "numberOfFilteredEvents"
2019-04-09 14:46:54 +02:00
jchipmunk
7c0ae3ee20
DBZ-1212 SLF4J usage issues
2019-04-04 21:32:12 +02:00
Joy Gao
f3220e9766
DBZ-1207 MySQL connection timeout after bootstrapping a new table
2019-04-02 12:52:39 +02:00
Jiri Pechanec
b90274cc63
DBZ-1194 Convert nulls even for key
2019-03-29 21:20:53 +01:00
ShubhamRwt
540a951211
DBZ- 362 Adding WhitespaceAfter check to Checkstyle
2019-03-28 09:24:11 +01:00
Jenkins user
8b0edd1871
[maven-release-plugin] prepare for next development iteration
2019-03-25 12:16:31 +00:00
Jenkins user
56f98a48b2
[maven-release-plugin] prepare release v0.9.3.Final
2019-03-25 12:16:30 +00:00
Jiri Pechanec
7524b1ec89
DBZ-1169 Mark outbox as incubating
2019-03-25 11:27:44 +01:00
Renato Mefi
0847870d21
DBZ-1169 Test for invalid Outbox operations
...
Also removed unused code
2019-03-25 11:27:44 +01:00
Renato Mefi
be9c70db64
DBZ-1169 Ensure SMT configuration is valid
...
Also had to update a validator
2019-03-25 11:27:44 +01:00
Renato Mefi
87a3278dfe
DBZ-1169 Support user set Schema version
...
The cache mechanism had to be adapted in order to support non-versioned
and versioned schemas, a test now confirms it's the same valueSchema
instance created once.
2019-03-25 11:27:44 +01:00
Renato Mefi
4aec4d5e92
DBZ-1169 Schema should inherit from original type
...
To allow more flexibility we should proxy the new Event Schema fields
based on the original table columns which Debezium is capturing.
The Schema is now built one time during the first Record in order to
detect those types which are only available within the Record.
2019-03-25 11:27:44 +01:00
Renato Mefi
c14ce54a6f
DBZ-1169 Support additional user fields
2019-03-25 11:27:44 +01:00
Renato Mefi
2a8806e15c
DBZ-1169 Support setting Record timestamp
...
It's a good practice to depend on the Kafka metadata instead of custom
dates in the payload, this way for instance when using KStreams with
Tumbling Window the dates are correctly matched.
2019-03-25 11:27:44 +01:00
Renato Mefi
8b689d7f03
DBZ-1169 Implement RegexRouter based on config
2019-03-25 11:27:44 +01:00
Renato Mefi
f0f13ed4a4
DBZ-1169 Implement basic behavior
2019-03-25 11:27:44 +01:00
Renato Mefi
ebf36e1ddb
DBZ-1169 Support skipping deletions and tombstones
2019-03-25 11:27:44 +01:00
Renato Mefi
6512c0b387
DBZ-1169 Add Configuration for Outbox Transform
2019-03-25 11:27:44 +01:00
Jiri Pechanec
9b405aa84d
DBZ-1039 Add missing spaces
2019-03-25 10:23:14 +01:00
shubham
8cca21e969
DBZ-1039 Make all ifs with braces
2019-03-25 10:23:14 +01:00
Addison Higham
8e21139ca3
DBZ-1082 Add new custom recovery mode, more metadata
...
This commit does a few things:
- Refactors snapshot modes to be encapsulated by an interface and
to only use that interface in determining when to snapshot and in
determing the type of the `RecordProducer` interface to instantiate
- Refactors the configuration of existing snapshot modes to tie the
existing snapshot modes to their aligned implementation
- Adds a new snapshot.mode, custom, and a new configuration option to
specify a custom implementation that will be loaded by the class loader
- Changes the visibility of some classes to allow for custom snapshot
modes to get enough context to make an informed choice
- Adds some metadata about slots (the catalog_xmin) to give a full idea
of the state of slots which can be useful in implementing snapshot
modes (which is also configurable, as it can add some overhead)
Together, these changes allow for a much broader flexibility got end
users to implement a snapshot mode that can do more advanced snapshots,
such as partial recovery or for partial snapshots for tables where not
all records are needed.
This could also be seen as superseeding the
`snapshot.select.statement.overrides` to allow for users to dynamically
build queries based on the state of the slot and the offsets consumed.
2019-03-24 11:56:40 +01:00
Jon Casstevens
2efdae1ffd
DBZ-1179 Set the default replication factor property for history topics when none is provided
2019-03-21 12:07:10 +01:00
Gunnar Morling
2ea87727cf
DBZ-1174 Using Instant instead of long for representing timestamps
2019-03-12 17:19:13 +01:00
Jiri Pechanec
71765a2ab2
DBZ-1170 Detect and handle errors like ULE
2019-03-11 10:29:54 +01:00
Josh Stanfield
e4b7b90637
DBZ-1162 fix to ensure hstore snapshots behave the same as streams
2019-03-04 13:39:50 +01:00
Jenkins user
50a7c568fa
[maven-release-plugin] prepare for next development iteration
2019-02-23 09:53:58 +00:00
Jenkins user
28f3839804
[maven-release-plugin] prepare release v0.9.2.Final
2019-02-23 09:53:58 +00:00
Gunnar Morling
6787d17d54
DBZ-1141 Misc. clean-up;
...
* Removing redundant check for date mapping type
* Always using String as fallback value for temporal values where needed
* Pulling fallback temporal values up to JdbcValueConverters
2019-02-21 15:02:51 +01:00
Jiri Pechanec
41ba7128e3
DBZ-1141 Correct default falback values for connect date types
2019-02-21 15:02:51 +01:00
Keith Barber
95b2290df2
DBZ-1149 Ensure consistent Java types for fallback values when converting
2019-02-21 15:02:51 +01:00
Jiri Pechanec
ff5aaf2e9a
DBZ-1153 Support for special char names
2019-02-20 15:25:45 +01:00
Gunnar Morling
510e9415f9
DBZ-1137 Some clean-up;
...
* Using existing justifyLeft() method
* Giving expected values as Duration
* Removing unused methods
2019-02-19 18:41:09 +01:00
Jiri Pechanec
0d60e60243
DBZ-1137 Default for TIME can be generic interval value
2019-02-19 13:40:01 +01:00
Jenkins user
b96e5fee0d
[maven-release-plugin] prepare for next development iteration
2019-02-13 11:13:44 +00:00
Jenkins user
3de2d04bcd
[maven-release-plugin] prepare release v0.9.1.Final
2019-02-13 11:13:44 +00:00
Jiri Pechanec
9049078607
DBZ-997 Handle de-sync of message and JDBC PK info
2019-02-13 10:13:12 +01:00
tomaz.fernandes
4e6b44d925
DBZ-1122 Fixed a potential NPE in FileDatabaseHistory
2019-02-12 13:17:09 +01:00
Gunnar Morling
2a486ecfff
DBZ-1019 Removing legacy methods from Metronome
2019-02-11 18:11:34 +01:00
Jiri Pechanec
fa6fcd8487
DBZ-1019 Guard against wall-clock change
2019-02-11 18:11:34 +01:00
Jiri Pechanec
4d76243227
DBZ-1121 Emit ALTER event for updated tables
2019-02-09 20:03:57 +01:00
Gunnar Morling
7076deba5a
DBZ-1118 Adding JUnit rule to skip tests depending on Postgres version
2019-02-04 14:43:19 +01:00
Jiri Pechanec
16620f0bf9
DBZ-1040 Cleaning up event formatting
2019-02-04 12:39:07 +01:00
Gunnar Morling
99caad60d8
DBZ-1040 Changing resolution of "lag behind source" to milli-seconds;
...
Also using Duration/Instant types internally.
2019-02-04 12:39:07 +01:00
Gunnar Morling
f1c4234248
DBZ-1040 Removing value from metrics events
2019-02-04 12:39:07 +01:00
Gunnar Morling
913e0bc5c8
DBZ-1040 Making metadata provider a member of Metrics instead of passing it for each onEvent() call
2019-02-04 12:39:07 +01:00
Gunnar Morling
399f91ce84
DBZ-1040 Typo fix
2019-02-04 12:39:07 +01:00
Gunnar Morling
27274d664f
DBZ-1040 Passing source as DataCollectionId instead of Object
2019-02-04 12:39:07 +01:00
Jiri Pechanec
de171917dc
DBZ-1040 Improve event to string formatting
2019-02-04 12:39:07 +01:00
Jiri Pechanec
a621e43d8b
DBZ-1040 Expose transaction id
2019-02-04 12:39:07 +01:00
Jiri Pechanec
213d4a42ca
DBZ-1040 Metrics for internal queue
2019-02-04 12:39:07 +01:00
Jiri Pechanec
d993ee265e
DBZ-1040 Metrics for lag behind source, offset and tx count
2019-02-04 12:39:07 +01:00
jchipmunk
acbc94e8b0
DBZ-1112 rename prepareQuery() to prepareQueryWithBlockingConsumer()
...
Reason:
reference to prepareQuery is ambiguous
[ERROR] both method prepareQuery(java.lang.String,io.debezium.jdbc.JdbcConnection.StatementPreparer,io.debezium.jdbc.JdbcConnection.BlockingResultSetConsumer) in io.debezium.jdbc.JdbcConnection and method prepareQuery(java.lang.String,io.debezium.jdbc.JdbcConnection.StatementPreparer,io.debezium.jdbc.JdbcConnection.ResultSetConsumer) in io.debezium.jdbc.JdbcConnection match
2019-01-30 09:36:09 +01:00
jchipmunk
ff4e38cc46
DBZ-1112 Strings.join() doesn't apply conversation for first element
...
Replace:
- Integer.parseInt() to Integer.valueOf()
- Short.parseShort() and new Short() to Short.valueOf()
- Long.parseLong() to Long.valueOf()
2019-01-30 09:36:09 +01:00
Gunnar Morling
2a80931d03
DBZ-962 Avoiding Short constructor
2019-01-29 10:28:48 +01:00
Gunnar Morling
e84c6e2238
DBZ-962 Avoiding dependency to JAXB
2019-01-29 10:28:48 +01:00
Jenkins user
c5b7d21d3e
[maven-release-plugin] prepare for next development iteration
2019-01-28 11:07:04 +00:00
Jenkins user
f1ae79ff73
[maven-release-plugin] prepare release v0.9.0.CR1
2019-01-28 11:07:04 +00:00
Gunnar Morling
ccff79e07d
DBZ-1105 Removing TableImpl#columnNames field
2019-01-28 10:23:56 +01:00
Gunnar Morling
a27c29765a
DBZ-947 Formatting
2019-01-28 09:32:57 +01:00
Grzegorz Kołakowski
64c45c7490
DBZ-947 Reset initial transaction isolation level at snapshot end
2019-01-28 09:32:57 +01:00
Gunnar Morling
ebe5fd7e85
DBZ-1067 Adding SourceRecordAssert
2019-01-23 08:31:22 +01:00
Gunnar Morling
9665af3ebc
DBZ-1086 Adding Ivan Kovbas to COPYRIGHT.txt
2019-01-18 21:43:45 +01:00
Ivan Kovbas
81f031cb7c
DBZ-1086 Added functionality to gracefully handle key-less messages in ByLogicalTableRouter transformation.
2019-01-18 21:38:52 +01:00
Gunnar Morling
cedef89a48
DBZ-1089 Using Strings#isNullOrEmpty(); adding test
2019-01-18 10:07:20 +01:00
Jiri Pechanec
28c9734685
DBZ-1089 Use only schema name when both catalog and schema is present
2019-01-18 10:07:20 +01:00
Jiri Pechanec
25156730f0
DBZ-1088 use correct key for update of PK insert event
2019-01-17 14:28:18 +01:00
Jiri Pechanec
ceb6c62721
DBZ-1064 Remove lazy fallback values
2019-01-16 13:01:36 +01:00
Jiri Pechanec
536e517c08
DBZ-1064 Geometry default value changes; fixes for default suppliers
2019-01-16 13:01:36 +01:00
Gunnar Morling
532c17f8aa
DBZ-1064 Using dedicated functional interface instead of Consumer;
...
* Commenting
* Moving type from "util" to "jdbc"
2019-01-16 13:01:36 +01:00
Jiri Pechanec
bff7eea734
DBZ-1064 Use convert value template
2019-01-16 13:01:36 +01:00
Jiri Pechanec
920e0cbd3f
DBZ-1064 Set default value only for non-nullable fields
2019-01-16 13:01:36 +01:00
Gunnar Morling
de356896c0
DBZ-1029 Adding one more test
2019-01-15 17:41:42 +01:00
Amit Sela
b0b7d942a3
DBZ-1073 Adding scale as schema parameter, if present
2019-01-11 15:40:30 +01:00
Grzegorz Kołakowski
91c72738c0
DBZ-1067 Add column blacklist field to RelationalDatabaseConnectorConfig
2019-01-09 18:13:26 +01:00
Jenkins user
5275f73424
[maven-release-plugin] prepare for next development iteration
2018-12-19 13:06:12 +00:00
Jenkins user
b6569c18ae
[maven-release-plugin] prepare release v0.9.0.Beta2
2018-12-19 13:06:12 +00:00
Jiri Pechanec
0e98bb428b
DBZ-978 Make offset readable in last event
2018-12-19 11:03:01 +01:00
luobo
fcfc019b6b
fix the wrong words
2018-12-14 13:05:14 +01:00
Gunnar Morling
47f22feddc
DBZ-978 Misc. clean-up
2018-12-13 21:17:23 +01:00
Jiri Pechanec
edec1c3090
DBZ-978 Added last event and captured tables metrics
2018-12-13 20:52:11 +01:00
Gunnar Morling
f89fc0bb14
DBZ-966 Awaiting snapshot delay only when actually doing a snapshot
2018-12-13 14:29:54 +01:00
Gunnar Morling
5542c0de29
DBZ-966 Making sure Postgres connector can be stopped while awaiting initial snapshot delay;
...
* Also skipping snapshotting when requested to stop during initial delay
* Showing remaining delay time in logs
* Adding missing config
2018-12-13 14:29:54 +01:00
Gunnar Morling
7a577161da
DBZ-966 Pushing snapshot delay logic into coordinator;
...
Using timer + metronome to ensure the delay phase will be cancelled upon connector shutdown
2018-12-13 14:29:54 +01:00
Grzegorz Kołakowski
7f8c0e8ff1
DBZ-966 Enable to delay initial snapshot in HistorizedRelationalSnapshotChangeEventSource
2018-12-13 14:29:54 +01:00
Grzegorz Kołakowski
2a1934eeb1
DBZ-966 Make snapshot.delay.ms global property
2018-12-13 14:29:54 +01:00
Jiri Pechanec
2b2ff0754d
DBZ-960 Run SnapshotReader in a single transaction
2018-12-11 14:15:53 +01:00
Jiri Pechanec
284ae98adf
DBZ-1003 Initialize database history
2018-12-03 21:52:05 +01:00
Renato Mefi
8c1ebc2a8f
DBZ-971 Unwrap can add data operation header
2018-11-30 12:06:18 +01:00
Renato Mefi
0af8dcfde0
DBZ-971 Ensure Envelope unwrap propagates headers
2018-11-30 12:06:18 +01:00
Jenkins user
db1d3a7fb8
[maven-release-plugin] prepare for next development iteration
2018-11-20 16:15:14 +00:00
Jenkins user
f83db82cea
[maven-release-plugin] prepare release v0.9.0.Beta1
2018-11-20 16:15:14 +00:00
Gunnar Morling
6bd4024618
DBZ-776 Misc. improvements;
...
* Renaming getTimeSinceLastEvent() to getMilliSecondsSinceLastEvent()
* Further unifying metrics implementation across connectors
* Emitting event in EventDispatcher also if event is filtered out
* Typo fixes
2018-11-16 08:52:07 +01:00
Jiri Pechanec
4510e2bbe6
DBZ-776 Cleanup after review
2018-11-16 08:52:07 +01:00
Gunnar Morling
360714a5a1
DBZ-776 Formatting and minor clean-up
2018-11-16 08:52:07 +01:00
Jiri Pechanec
b44c9fd04f
DBZ-776 A first set of metrics implemented in new framework
2018-11-16 08:52:07 +01:00
Jiri Pechanec
4cdc3e669b
DBZ-776 Extract metrics to a common code
2018-11-16 08:52:07 +01:00
Gunnar Morling
9436778a1d
DBZ-812 Misc. clean-up
2018-11-13 10:06:22 +01:00
Jiri Pechanec
33f6529614
DBZ-812 PK list is not-null for no PKs on table
2018-11-13 09:41:03 +01:00
Jiri Pechanec
5930c580f7
DBZ-812 Change extract column metadata
2018-11-13 09:41:03 +01:00
Jiri Pechanec
839d7c80eb
DBZ-812 Prep statements with different parameters; Extract table schema code
2018-11-13 09:41:03 +01:00
Gunnar Morling
92704ce394
DBZ-963 Removing hard-coded references to "target" dir;
...
Also injecting actual build dir via system variable.
Making DATA_DIR a simple string.
2018-11-08 10:35:07 +01:00
Anton Martynov
3401cd23ea
DBZ-963 Allowing to customize the directory where tests are storing their data
2018-11-08 10:34:10 +01:00
Gunnar Morling
9994172860
DBZ-953 Pulling decimal mode handling up to RelationalDatabaseConnectorConfig;
...
Also using it in MySQL connector.
2018-11-08 09:23:28 +01:00
Grzegorz Kołakowski
2d5295805c
DBZ-941 Add connectionCreated template method in HistorizedRelationalSnapshotChangeEventSource
...
The method allows to define steps which have to be taken just after the
database connection is created (e.g. setting snapshot isolation level).
By default no operation is executed.
2018-10-30 13:35:57 +01:00
Jenkins user
d952f5dfb0
[maven-release-plugin] prepare for next development iteration
2018-10-04 11:59:14 +00:00
Jenkins user
ff9b70278b
[maven-release-plugin] prepare release v0.9.0.Alpha2
2018-10-04 11:59:13 +00:00
jchipmunk
05ba99bb0a
DBZ-918 Adding Debezium connector field to source info
...
This will allow consumers to recognize the Debezium connector used for creating a given message, helping them to adjust their behavior for a variety of connectors.
2018-10-04 09:00:13 +02:00
Gunnar Morling
39a47fabfa
DBZ-899 Using custom statement to obtain SQL type info in order to avoid N+1 issues with PgDatabaseMetaData#getTypeInfo()
2018-09-19 09:51:38 +02:00
Gunnar Morling
3331d4c1a9
DBZ-899 Removing unused field;
...
Also inlining method only used in one place.
2018-09-19 09:51:38 +02:00
Jiri Pechanec
2253eaa6a6
DBZ-819 JdbcConnection is not thread safe
2018-09-18 09:05:36 +02:00
Jiri Pechanec
05ce2e3063
DBZ-819 Cache prepared statements in connection
2018-09-18 09:05:36 +02:00
jchipmunk
b0feaf496a
DBZ-633 Adding "field.blacklist" property for MongoDB connector
...
The "field.blacklist" configuration property is an optional comma-separated list of the fully-qualified names of fields that should be excluded from change event message values. Fully-qualified names for fields are of the form "databaseName.collectionName.fieldName.nestedFieldName", where "databaseName" and "collectionName" may contain the wildcard (*) which matches any characters.
Although the "field.blacklist" configuration property allows you to remove fields from the event values, the "_id" field is always included in the event’s key.
2018-09-14 12:54:11 +02:00
Gunnar Morling
5878e5105f
DBZ-878 Using LRU eviction strategy
...
[As recommended](4961277637 (commitcomment-30412629)
) by Ben Manes, the LIRS implementation seems to provide no advantage and isn't well tested.
2018-09-06 11:21:31 +02:00
Gunnar Morling
4961277637
DBZ-878 Making topic name cache size bound;
...
* Imported BoundedConcurrentHashMap from Hibernate ORM as a thread-safe concurrent cache.
2018-09-05 12:56:53 +02:00
Gunnar Morling
e1bbbd7992
DBZ-865 DBZ-878 Replacing invalid topic name characters with "_";
2018-09-05 12:56:53 +02:00
Gunnar Morling
eba134817f
DBZ-894 Making TableIdToStringMapper dedicated functional interface with specifically named method
2018-09-04 12:43:50 +02:00
Jiri Pechanec
1373ac8475
DBZ-894 Introduce explicit mapping functional type
2018-09-04 12:39:10 +02:00
Jiri Pechanec
3e0648a42c
DBZ-894 Customize TableId comparison per-connector in filters
2018-09-04 09:18:15 +02:00
Gunnar Morling
985999b4af
DBZ-872 Making MySqlAntlrDdlParser#tableFilter final
2018-08-24 08:12:54 +02:00
Jiri Pechanec
63ee65bb7d
DBZ-872 Honor filters in ALTER TABLE parsing
2018-08-24 08:12:54 +02:00
Jiri Pechanec
82a93cdac5
DBZ-859 Heartbeat is sent after pipeline snapshot
2018-08-23 11:44:53 +02:00
Jiri Pechanec
985e03e7b5
DBZ-859 Force heartbeat after snapshot completion
2018-08-23 11:44:53 +02:00
Maciej Bryński
947abf9815
DBZ-857 Ability to rewrites deleted records
2018-08-14 10:37:39 +02:00
artiship
57fa31e1bc
DBZ-854 Correct param name for excludeColumns(String fullyQualifiedTableNames)
2018-08-14 08:39:28 +02:00
LiuHanlin
41e16f4a4f
DBZ-853 Fix kafka database history storage miscount attemp number even if there are more records to consume
2018-08-13 20:26:48 +02:00
Jenkins user
e00dad127f
[maven-release-plugin] prepare for next development iteration
2018-07-26 08:00:12 +00:00
Jenkins user
16bfd5c700
[maven-release-plugin] prepare release v0.9.0.Alpha1
2018-07-26 08:00:12 +00:00
Gunnar Morling
3061c1dc0b
DBZ-815 Passing offset to Heartbeat#heartbeat();
...
That's simpler to grasp than the approach of passing a supplier lambda to the constructor.
Also it allows to pass on the offset via local variables instead of instance fields in some cases.
2018-07-25 14:49:52 +02:00
Gunnar Morling
0a659c0159
DBZ-815 Ensuring latest offset is propagated also if change events relate to non-whitelisted tables
2018-07-25 14:49:52 +02:00
Gunnar Morling
fa68c1a158
DBZ-816 Preparing code for database history set-up for re-use
2018-07-25 11:54:15 +02:00
Jiri Pechanec
e86ddc0ab2
DBZ-40 Add blocking version of MultiResultSetConsumer
2018-07-25 11:51:09 +02:00
Gunnar Morling
bd4f3d60fa
DBZ-804 Simplifying construction of VariableScaleDecimal
2018-07-24 20:48:52 +02:00
Gunnar Morling
98c329aabe
DBZ-40 Adding SnapshottingTask#toString()
2018-07-24 18:53:32 +02:00
Gunnar Morling
0362b333bf
DBZ-804 Better schema comparison in tests; preparing byte conversion
2018-07-24 05:18:52 +02:00
Gunnar Morling
9814a5c82c
DBZ-803 Finalizing snapshot in offsets also for schema-only snapshots
2018-07-23 06:44:04 +02:00
Gunnar Morling
2905cc498b
DBZ-800 Don't expect that partition is a Map<String, String>
2018-07-20 13:37:54 +02:00
Gunnar Morling
fe53360f30
DBZ-800 Avoiding "mysql" in commonly used heartbeat key schema
2018-07-20 13:37:54 +02:00
Gunnar Morling
86a4731587
DBZ-800 Emitting heartbeat events in generic event dispatcher
2018-07-20 13:37:54 +02:00
Gunnar Morling
26106cdd8e
DBZ-800 Removing unused method from Heartbeat
2018-07-20 13:37:54 +02:00
Jiri Pechanec
0e35439019
DBZ-40 Snapshotting and connector restart
2018-07-18 14:39:11 +02:00
Gunnar Morling
a5b5e7d9eb
DBZ-627 Using unfified TopicSelector for MongoDB, too
2018-07-18 12:36:07 +02:00
Gunnar Morling
20db9299c5
DBZ-627 Unifying TopicSelector implementations
2018-07-18 12:36:07 +02:00
Gunnar Morling
610da70cc5
DBZ-801 Parameterizing ChangeEventQueue<DataChangeEvent>
2018-07-18 10:30:22 +02:00
Gunnar Morling
80085567ae
DBZ-720 Proper check for previous unfinished snapshot
2018-07-18 10:07:50 +02:00
Gunnar Morling
33170d4c3d
DBZ-40 Pulling up some common code to HistorizedRelationalDatabaseSchema
2018-07-18 10:07:50 +02:00
Gunnar Morling
422a303f87
DBZ-720 Signaling cancellation of snapshot through InterruptedException
2018-07-17 13:11:02 +02:00
Jiri Pechanec
f118e37da0
DBZ-40 Changes to support SQL Server connector
2018-07-13 22:23:00 +02:00
Gunnar Morling
c5e2d5f9e7
DBZ-720 Making scan of single table interruptable;
...
Also better logging.
2018-07-13 19:42:18 +02:00
Gunnar Morling
648d695c08
DBZ-720 Preparing HistorizedRelationalSnapshotChangeEventSource to support data snapshotting
2018-07-13 19:42:18 +02:00
Gunnar Morling
aa1272cc21
DBZ-720 Re-using single instance of streaming event receiver in EventDispatcher
2018-07-13 09:51:15 +02:00
Gunnar Morling
657650c581
DBZ-720 Passing change event emitter directly to dispatch methods;
...
The indirection of going through a supplier wasn't really necessary
2018-07-13 09:51:15 +02:00
Gunnar Morling
a565361e56
DBZ-720 Making SnapshotContext auto-closeable
2018-07-13 09:51:15 +02:00
Gunnar Morling
986df43649
DBZ-720 Extracting HistorizedRelationalSnapshotChangeEventSource from Oracle connector
2018-07-13 09:51:15 +02:00
Gunnar Morling
1523f230ca
DBZ-793 Using TableFilter consistently;
...
Only the MySQL connector's Filters class still uses Predicate for the time being, so to avoid to much merging trouble with DBZ-175.
2018-07-11 13:16:44 +02:00
Jenkins user
f9b8d830a8
[maven-release-plugin] prepare for next development iteration
2018-07-11 07:36:30 +00:00
Jenkins user
290ded678f
[maven-release-plugin] prepare release v0.8.0.Final
2018-07-11 07:36:29 +00:00
Jenkins user
033db6659d
[maven-release-plugin] prepare for next development iteration
2018-07-04 07:07:44 +00:00
Jenkins user
696f35f2c0
[maven-release-plugin] prepare release v0.8.0.CR1
2018-07-04 07:07:44 +00:00
Gunnar Morling
99048365c9
DBZ-771 Unsetting default value when changing a column's type
2018-07-03 11:55:20 +02:00
Gunnar Morling
c7d5288d40
DBZ-771 Making sure causing DDL statement is logged also if default value can't be parsed
2018-07-03 11:55:20 +02:00
Gunnar Morling
dcd6b01134
DBZ-644 Simplifying RelationalDatabaseSchema constructor;
...
Also retrieving logical name via CommonConnectorConfig#getLogicalName() in more places
2018-07-03 07:03:59 +02:00
Gunnar Morling
b0980b994c
DBZ-644 Adding test for Postgres
2018-07-03 07:03:59 +02:00
Gunnar Morling
068aa85bd6
DBZ-644 Misc. clean-up and tests;
...
* Using parameter keys under "__debezium" namespace
* More expressive names
* Adding tests
2018-07-03 07:03:59 +02:00
Gunnar Morling
8744488c8a
DBZ-644 Unifying retrieval of ColumnMappers in RelationalDatabaseSchema
2018-07-03 07:03:59 +02:00
orr.ganani
ac515b8064
DBZ-644 change Original Data Type mapper and add a test
2018-07-03 07:03:59 +02:00
orr.ganani
747184c572
DBZ-644 add JDBC data type as additional metadata to DBZ events, if configuration is opted in
2018-07-03 07:03:59 +02:00
Gunnar Morling
c4c8cbc3ab
DBZ-773 Moving management of Tables to RelationalDatabaseSchema
2018-06-29 09:09:10 +02:00
Gunnar Morling
bbfbdf6fab
DBZ-773 Moving management of table schemas to RelationalDatabaseSchema
2018-06-29 09:09:10 +02:00
Gunnar Morling
a292b05a96
DBZ-751 Propagating DECIMAL column precision to Avro schemas
2018-06-27 14:48:59 +02:00
Gunnar Morling
b27421ddd0
DBZ-759 Testing via SchemaUtil;
...
* Making RecordWriter private
* Removing quotes around string representation of byte arrays
2018-06-26 12:03:53 +02:00
Andreas Bergmeier
82bac78ba8
DBZ-759 Add Test to ensure correct serialization of byte arrays
...
Needed to make RecordWriter public to have access in tests.
2018-06-26 11:50:54 +02:00
Andreas Bergmeier
71abca2afb
DBZ-759 Fix unusable array information in Serialization
...
According to ErrorProne, (implicitly) calling toString on the array does
not give useful information.
Also applying Base64 encoding is strange here.
2018-06-26 11:50:54 +02:00
Gunnar Morling
8d0d35762e
DBZ-759 Removing superfluous (and broken) ColumnEditorImpl#compareTo() implementation
2018-06-25 17:04:45 +02:00
Gunnar Morling
bf7a5018ca
Setting POM version back to 0.8.0-SNAPSHOT
2018-06-22 12:21:03 +02:00
Gunnar Morling
357102158a
DBZ-759 Fixing broken Document#setArray() method
2018-06-22 11:03:00 +02:00
Gunnar Morling
ce81f37990
DBZ-759 Adding unit test
2018-06-22 09:19:45 +02:00
Andreas Bergmeier
7417baea4d
DBZ-759 Fix equality comparison for BinaryValue
...
If value is binary or string, it should be better to compare the content
of the actual byte arrays.
According to ErrorProne you use reference equality when calling equals on
an array.
Part of https://issues.jboss.org/browse/DBZ-759
2018-06-22 09:19:45 +02:00
Andreas Bergmeier
333d6cb57d
DBZ-759 Fix hashCode of BinaryValue
...
According to ErrorProne, the hashCode of a byte array returns useless
information.
Part of https://issues.jboss.org/browse/DBZ-759
2018-06-22 09:19:41 +02:00
Andreas Bergmeier
d374ca0464
DBZ-759 Fix ColumnImpl.scale equality check
...
According to ErrorProne, checking Optional via operator == leads to
reference equality check. Probably want rather to check for contained
values.
2018-06-22 09:08:27 +02:00
Jenkins user
db42e4657a
[maven-release-plugin] prepare for next development iteration
2018-06-21 14:07:45 +00:00
Jenkins user
c4b8ecaa99
[maven-release-plugin] prepare release v0.8.0.Beta1
2018-06-21 14:07:45 +00:00
Gunnar Morling
96c59a1568
DBZ-20 Moving debezium-connector-oracle from main to incubator repo
2018-06-20 13:05:37 +02:00
Gunnar Morling
b83f1493a2
DBZ-20 Avoiding Optional as method parameter
2018-06-20 13:05:37 +02:00
Gunnar Morling
dce1aa29f1
DBZ-20 Oracle precision supports negative numbers
2018-06-20 13:05:37 +02:00
Gunnar Morling
f4e3668ebf
DBZ-20 Tune up timeouts/connector/oracle/OracleStreamingChangeEventSource.java
2018-06-20 13:05:37 +02:00
Gunnar Morling
cf6219ccda
DBZ-20 Committing processed offsets in the DB, allowing log files to be released
2018-06-20 13:05:37 +02:00
Jiri Pechanec
661c34fc6b
DBZ-20 Use fluent API in ColumnEditor
2018-06-20 13:05:37 +02:00
Jiri Pechanec
232a1d5573
DBZ-20 Support for day to second interval
2018-06-20 13:05:37 +02:00
Jiri Pechanec
89694ffbbf
DBZ-20 Support for year to month interval
2018-06-20 13:05:37 +02:00
Jiri Pechanec
28b844bf99
DBZ-20 Added ANSI double precision, real and variable scale number datatypes
2018-06-20 13:05:37 +02:00
Jiri Pechanec
10ddb69dea
DBZ-20 A subset of string, time and number datatypes
2018-06-20 13:05:37 +02:00
Gunnar Morling
603f02e70d
DBZ-20 Excluding generated sources from CheckStyle
2018-06-20 13:05:37 +02:00
Gunnar Morling
e8614c7890
DBZ-20 Adding table whitelist/blacklist connector options;
...
* Restructuring OracleSnapshotChangeEventSource into smaller methods
2018-06-20 13:05:37 +02:00
Gunnar Morling
1e87fae023
DBZ-20 Recovering database history
2018-06-20 13:05:37 +02:00
Gunnar Morling
0733110696
DBZ-20 Recording schema history;
...
This records the DDL for DDL events captured during streaming. For the
initial schema snapshot, a JSON-style representation of the captured
Table objects is used in a new field of HistoryRecord, as the DDL
returned by dbms_metadata.get_ddl() isn't fully parseable by our
grammar.
2018-06-20 13:05:37 +02:00
Gunnar Morling
1a7786d254
DBZ-20 Further simplifying threading model and stopping logic
2018-06-20 13:05:37 +02:00
Gunnar Morling
d8a9865e51
DBZ-20 Some more docs
2018-06-20 13:05:37 +02:00
Gunnar Morling
225c0f05a6
DBZ-20 Extracting RelationalChangeRecordEmitter base class
2018-06-20 13:05:37 +02:00
Gunnar Morling
979c60d956
DBZ-20 Handling update events
2018-06-20 13:05:37 +02:00
Gunnar Morling
24e22f4985
DBZ-20 Simpler and more robust interruption handling in ChangeEventSourceCoordinator
2018-06-20 13:05:37 +02:00
Gunnar Morling
d7e196a18e
DBZ-20 Initial import of Oracle connector based on XStream
2018-06-20 13:05:37 +02:00
Gunnar Morling
9eb4b90ec9
DBZ-191 Adding record validations
2018-06-15 20:23:17 +02:00
Gunnar Morling
84dd36df46
DBZ-252 Misc typo fixes and clean-up
2018-06-15 16:43:30 +02:00
Gunnar Morling
54ca30624d
DBZ-252 Misc. improvements;
...
* Dedicated getter for DDL mode
* Using Objects#equal()
* Typo fixes
2018-06-15 16:43:29 +02:00
Jiri Pechanec
9580c8c290
DBZ-252 Rebase to master
2018-06-15 11:42:24 +02:00
rkuchar
7d7f740721
DBZ-252 refactor parser listener
2018-06-15 11:42:24 +02:00
rkuchar
5c9e718436
DBZ-252 uncomment getting ddl parser instance from configuration + improve/refactor dataType resolver for ANTLR
2018-06-15 11:42:24 +02:00
rkuchar
99eac9a8e2
DBZ-252 some test fixes + separate ddl test for antlr parser
2018-06-15 11:42:24 +02:00
rkuchar
22151250fa
DBZ-252 refactor proxy listener delegation
2018-06-15 11:42:24 +02:00
rkuchar
07212043b5
DBZ-252 test fixes + grammar fixes + some bug repairs in antlr parser
2018-06-15 11:42:23 +02:00
rkuchar
1124f81d94
DBZ-252 parse set and use statements
2018-06-15 11:42:23 +02:00
rkuchar
b4480c55b7
DBZ-252 parse database queries (create, alter, delete), parse name tokens without quotes, add new Mysql connector configuration field for choosing ddl parsing mode
2018-06-15 11:42:23 +02:00
rkuchar
5d911d511f
DBZ-252 signal event for truncate table into schema changes
2018-06-15 11:42:23 +02:00
rkuchar
32d181480d
DBZ-252 fix troubles with generalized system variables + add new data types that was missing in grammar
2018-06-15 11:42:23 +02:00
rkuchar
85e8146d1f
DBZ-252 implementation of scope synonym for local and session scope in MySQL
2018-06-15 11:42:23 +02:00
rkuchar
5851d1f07d
DBZ-252 fix initialization of system variables object + add default scope for variales in case that scope will no be set
2018-06-15 11:42:23 +02:00
rkuchar
9311c82bc5
DBZ-252 reformat code to not have anything after closing "}"
2018-06-15 11:42:23 +02:00
rkuchar
782ab75160
DBZ-252 move listener support from base to only legacy implementation, refactor system variables for possible use with other DBMSs + introduce data type resolver for antlr mysql parser
2018-06-15 11:42:23 +02:00
rkuchar
b92e8ef760
DBZ-252 exclude logging of parsed comment
2018-06-15 11:42:23 +02:00
rkuchar
30e158aa71
DBZ-252 create table and drop table listeners
2018-06-15 11:42:23 +02:00
rkuchar
785c346bcb
DBZ-252 Exclude reusable logic from LegacyDdlParser
2018-06-15 11:42:23 +02:00
rkuchar
36e2f33bf6
DBZ-252 - extract creation of DdlParser interface
2018-06-15 11:42:23 +02:00
Jiri Pechanec
29f8891b4f
DBZ-578 Process timestamps without timezones as in server timezone
2018-06-11 15:27:08 +02:00
Jiri Pechanec
de0e1ad4b5
DBZ-702 Mask SASL configuration
2018-06-08 08:57:50 +02:00
Jiri Pechanec
176dcbbc0b
DBZ-709 PostgreSQL uses scale for time precision not length
2018-06-05 15:51:35 +02:00
luobo
5b33d81f00
DBZ-191 support default value of column in mysql
2018-06-04 10:43:53 +02:00
Gunnar Morling
61f576bb90
DBZ-706 Misc. clean-up
2018-06-01 11:23:30 +02:00
Stephen Powis
40d872f48c
DBZ-706 General cleanup
2018-06-01 11:23:30 +02:00
Stephen Powis
867202e0ca
DBZ-706 Slight refactoring / shuffling of code to validate source query field in snapshot tests
2018-06-01 11:23:12 +02:00
Jiri Pechanec
764a1d0d58
DBZ-693 SQL parsing in separate method
2018-05-28 12:35:47 +02:00
Jiri Pechanec
45bc7b1536
DBZ-693 On connect statements supported for PostgreSQL
2018-05-28 12:35:47 +02:00
Jiri Pechanec
f74a9fe059
DBZ-693 Initial SQL statements
2018-05-28 12:35:47 +02:00
Jiri Pechanec
f844054f50
DBZ-696 Support nanoseconds in timestamp data
2018-05-22 11:33:50 +02:00
Jiri Pechanec
09b28c0913
DBZ-694 Support milliseconds for pre-epoch dates
2018-05-22 11:22:06 +02:00
Rao
15a90548fb
DBZ-666 Supporting ordered snapshot using tables.whitelist config
2018-05-17 06:23:31 +02:00
Jiri Pechanec
0f0a5d4cd4
DBZ-687 Kafka 1.1.0
2018-05-14 09:37:33 +02:00
Omar Al-Safi
8ef9267808
DBZ-668 Added unit test and changed the key field name
2018-03-23 10:50:42 +01:00
Omar Al-Safi
21d2e0b8a9
DBZ-668 Changed the key schema for the heartebat messages from STRING to STRUCT
2018-03-23 10:50:42 +01:00
Jiri Pechanec
2b5370de1a
DBZ-667 Sceintific numbers parsing
2018-03-20 14:42:55 +01:00
Gunnar Morling
00b63bb808
DBZ-669 Closing AdminClient instance after usage
2018-03-20 13:07:42 +01:00
Jenkins user
f4e151b23a
[maven-release-plugin] prepare for next development iteration
2018-03-20 08:14:19 +00:00
Jenkins user
93b3252332
[maven-release-plugin] prepare release v0.7.5
2018-03-20 08:14:19 +00:00
Gunnar Morling
5f61cb167b
DBZ-655 Using AssertJ asserts in UnwrapFromEnvelopTest
2018-03-19 09:28:30 +01:00
Gunnar Morling
5358167446
DBZ-655 Adding test
2018-03-19 09:28:30 +01:00
Maciej Bryński
d5abb8415c
DBZ-655 Use cache to avoid using regexp replace
2018-03-19 09:28:23 +01:00
Gunnar Morling
d73c27d9bd
DBZ-657 Adding test
2018-03-18 18:26:27 +01:00
Jiri Pechanec
87bd3e9c2f
DBZ-657 Handle JSON with control chars not according to specs
2018-03-18 18:03:56 +01:00
Jiri Pechanec
9884a5ca1d
DBZ-663 disable cleaning of history topic based on size
2018-03-16 16:14:12 +01:00
Jiri Pechanec
62c7fe12f9
Do not log FLUSH RELAY LOGS statements
2018-03-16 09:51:48 +01:00
Jenkins user
daf27207be
[maven-release-plugin] prepare for next development iteration
2018-03-07 08:31:07 +00:00
Jenkins user
9c73774928
[maven-release-plugin] prepare release v0.7.4
2018-03-07 08:31:07 +00:00
Jiri Pechanec
327085164e
DBZ-611 Special values supported for double
2018-03-06 16:55:24 +01:00
Gunnar Morling
1f385c21f9
DBZ-611 Typo fix and formatting
2018-03-06 16:55:24 +01:00
Jiri Pechanec
424aefbbb4
DBZ-611 Decimal-> String supported for MySQL
2018-03-06 16:55:24 +01:00
Gunnar Morling
401cbae852
DBZ-632 Removing methods from HistoryRecord which where only used in tests;
...
Also adding a new test for HistoryRecord (de-)serialization
2018-03-02 05:28:16 +01:00
Gunnar Morling
d040ec4427
DBZ-351, DBZ-606 Misc. clean-up;
...
* Renaming DebeziumDecimal to SpecialValueDecimal
* Simplifying logic in PostgresValueConverter
2018-02-27 16:36:21 +01:00
Jiri Pechanec
2534696b21
DBZ-606 Exception thrown for special values when mode handling is not string
2018-02-27 16:36:21 +01:00
Jiri Pechanec
5827a7ac1b
DBZ-611 Decimals can be encoded as strings
2018-02-27 16:36:21 +01:00
Jiri Pechanec
c71707afc9
DBZ-351 wal2json usses unlimited precision too
2018-02-27 16:36:21 +01:00
Jiri Pechanec
0c0ac72568
DBZ-606 Type for handling special BigDecimals
2018-02-27 16:36:21 +01:00
Jiri Pechanec
ceaa7f8efe
DBZ-351 Numeric is passed with unlimited precision
2018-02-27 16:36:21 +01:00
Gunnar Morling
d89f4e91c6
DBZ-632 Removing unused method parameter
2018-02-23 21:54:41 +01:00
Gunnar Morling
eef1ad7c2a
DBZ-630 Refactoring around MongoDB task context;
...
* Renaming ConnectorTaskContext to CdcSourceTaskContext
* Renaming ReplicationContext to MongoDbTaskContext
* Making relationship from MongoDbTaskContext to ConnectionContext has-a instead of is-a
2018-02-21 12:04:41 +01:00
Gunnar Morling
bb12e521f8
DBZ-630 Pulling up getClock() to ConnectorTaskContext
2018-02-21 12:04:41 +01:00
Gunnar Morling
8264c20cf6
DBZ-630 Unifying common start-up logic across connectors
2018-02-21 12:04:41 +01:00
Gunnar Morling
7fe45db831
DBZ-626 Renaming AvroValidator to SchemaNameAdjuster;
...
Making apparent that this functionality doesn't solely validate but returns a new name actually
2018-02-20 09:26:47 +01:00
Gunnar Morling
cddd5fcc8a
DBZ-626 Passing schema validator as AvroValidator instance instead of Function
2018-02-20 09:26:47 +01:00
Jiri Pechanec
6e00924ee9
DBZ-625 Fix parsing of float without decimals
2018-02-20 08:47:43 +01:00
Gunnar Morling
b5856f37c7
DBZ-628 Unrelated typo fix
2018-02-20 06:34:42 +01:00
Gunnar Morling
8369f10d52
DBZ-628 Adding MAX_QUEUE_SIZE, MAX_BATCH_SIZE and POLL_INTERVAL_MS to CommonConnectorConfig;
...
Also using these options in PG connector
2018-02-20 06:34:42 +01:00
Gunnar Morling
5bc62dc862
DBZ-620 Removing method only used in tests
2018-02-19 12:18:37 +01:00
Gunnar Morling
ab11f48843
DBZ-620 Creating envelope schemas only once per table type
2018-02-19 12:18:37 +01:00
Jenkins user
6d0cd88e12
[maven-release-plugin] prepare for next development iteration
2018-02-15 04:15:34 +00:00
Jenkins user
7d1e1a989e
[maven-release-plugin] prepare release v0.7.3
2018-02-15 04:15:34 +00:00
Gunnar Morling
b1362f9db9
DBZ-278 Extracting broker config retrieval into its own method
2018-02-13 17:12:11 +01:00
Jiri Pechanec
90e4aa0dea
DBZ-278 Fail if topic is not created
2018-02-13 16:48:42 +01:00
Jiri Pechanec
4541fc53c9
DBZ-278 Explicit history storage initialization
2018-02-13 16:48:42 +01:00
Jiri Pechanec
ad7b92310e
DBZ-278 Test for broker without auto-created topics
2018-02-13 16:48:42 +01:00
Jiri Pechanec
55e81c458b
DBZ-278 Create database history topic
2018-02-13 16:48:42 +01:00
Jiri Pechanec
5a0c7c07b0
DBZ-609 DBZ-571 Refactor Postgres type handling
...
TypeRegistry introduced for Postgres connector
JDBC column does not have a special componentType
JDBC column provide a database specific type id
OID is a primary type identifier to be used in Postgres connector code - dropping JDB/OID dichotomy
2018-02-13 14:54:42 +01:00
Jiri Pechanec
dbac1429b2
DBZ-581 Improve error handling for replicators
2018-02-13 14:40:54 +01:00
Jiri Pechanec
ecdce6529d
DBZ-220 Null Heartbeat object. Messages contains key
2018-02-13 12:26:48 +01:00
Jiri Pechanec
682cabb84a
DBZ-220 Generate heartbeat events in binlog thread
2018-02-13 12:24:51 +01:00
Gunnar Morling
96b4023839
DBZ-220 Misc. improvements;
...
* interpreting heartbeat interval as MS
* adding Configuration#getDuration()
2018-02-13 12:24:51 +01:00
Jiri Pechanec
3c1ea8206b
DBZ-220 Refactor heartbeat to a separate class
2018-02-13 12:24:51 +01:00
Gunnar Morling
2e0b9e5e33
DBZ-582 Moving TOMBSTONES_ON_DELETE to CommonsConnectorConfig for re-use
2018-02-13 10:19:18 +01:00
Jiri Pechanec
d0bd1560ff
DBZ-576 Make DDL filter internal parameter
2018-02-12 11:22:28 +01:00
Jiri Pechanec
3740aee4e8
DBZ-576 Internal parameters
2018-02-12 11:22:28 +01:00
Gunnar Morling
a77c8d733a
DBZ-580, DBZ-586 Making enqueue() and thus snapshots in Postgres interruptable;
...
* ChangeEventQueue#enqueue() checks the interrupted state of the calling
thread now, raising an InterruptedException in case the interrupted flag
has been set (because the producer's thread executor has been stopped)
* RecordSnapshotProducer has been adjusted to check for the interrupted
regularly, aborting if it has been set
2018-02-11 10:05:06 +01:00
Gunnar Morling
45a9847d42
DBZ-580 Initial implementation of dedicated change message queue:
...
* To be used across connectors, unifying the enqueuing/polling logic and handling of related config options
* Using it for Postgres connector
2018-02-11 10:05:06 +01:00
Gunnar Morling
2a724d9611
DBZ-537 Misc. adjustments:
...
* Renaming ConfigurationHelper to Instantiator
* Doc improvements and typo fixes
* Bringing getInstance() methods into consistent order
* Raising exception instead of logging error if instantion fails
2018-02-09 15:45:57 +01:00
Jiri Pechanec
5be55ae8ff
DBZ-537 OffsetCommitPolicy supports Configuration constructor initialization
2018-02-09 15:19:48 +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
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
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
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
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
Peter Goransson
7d78357087
DBZ-443 Adding db-history recovery mode: schema_only_recovery
2018-01-23 09:17:39 +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
Jiri Pechanec
24bdcaf059
DBZ-516 Return control to Connect periodically
2018-01-18 14:13:58 +01:00
Gunnar Morling
9f433b1e24
DBZ-544 Comment fix
2018-01-17 15:16:37 +01:00
Jiri Pechanec
cdf44faba4
DBZ-544 Log matching DDL filter
2018-01-17 15:16:37 +01:00
Gunnar Morling
4d1d016acb
DBZ-392 Making table map and set dedicated classes just with the needed API
2018-01-17 11:21:02 +01:00
Jiri Pechanec
9f0f0fe5d4
DBZ-392 Support for MySQL running on lowercase filesystems
2018-01-17 11:21:02 +01:00
Gunnar Morling
b99bdf7fdc
DBZ-543 Removing a few unused methods
2018-01-15 14:37:46 +01:00
Gunnar Morling
5c88431c07
DBZ-494 Making tests more lenient towards specific List implementations;
...
also fixing a few typos.
2018-01-15 10:40:50 +01:00
Tom Bentley
5b839d3665
DBZ-540 Adding KafkaCluster#zkPort()
...
If you start a cluster (e.g. in a test) without specifying a port
you get a random port. Sometimes you might want to connect to the
embedded zookeeper instance (for instance, to make an assertion about
a znode). To do this you need to know the port number. So let's expose it.
2018-01-12 18:25:41 +01:00
Jiri Pechanec
0b269a6e41
DBZ-538 Improve invalid DDL statement reporting
2018-01-12 12:26:30 +01:00
Jiri Pechanec
2a7377a833
DBZ-455 Use valueOf instead of constructors
2018-01-05 02:32:37 +01:00
Jenkins user
6bb34b42f9
[maven-release-plugin] prepare for next development iteration
2017-12-20 07:15:12 +00:00
Jenkins user
16dcd4c980
[maven-release-plugin] prepare release v0.7.1
2017-12-20 07:15:12 +00:00
Jenkins user
5e09932cb9
[maven-release-plugin] prepare for next development iteration
2017-12-15 05:10:23 +00:00
Jenkins user
6c1d61e03b
[maven-release-plugin] prepare release v0.7.0
2017-12-15 05:10:23 +00:00
Gunnar Morling
4e8cedd094
DBZ-379 Postgres connector minimizes use of JDBC metadata
2017-12-13 12:20:37 +01:00
Jiri Pechanec
5ae236241b
DBZ-469 Fixed a backslash regex in testcase
2017-12-11 16:58:23 +01:00
Gunnar Morling
8e99dc3abd
DBZ-469 Adding one more test case
2017-12-11 16:58:23 +01:00
Gunnar Morling
1c55e41941
DBZ-469 Renaming listOfRegex() to setOfRegex();
...
* Simplifying test of that method
* Adding test to ensure correctness of default DDL pattern
2017-12-11 16:58:23 +01:00
Jiri Pechanec
86d9e109fc
DBZ-469 Filter our RDS heartbeat INSERT statements
2017-12-11 16:58:23 +01:00
rkerner
c7ac481c43
[DBZ-342] fix broken MySQL data type "TIME" handling
2017-11-29 20:34:12 +01:00
Gunnar Morling
a55227aa83
DBZ-464 Don't stop after reaching max retry count, but raise an exception instead;
...
Also increasing default value, as the connector can't start its work without fully recovering the history
2017-11-28 08:47:27 +01:00
Gunnar Morling
6537d904ce
DBZ-464 Reading until end offset of history topic
2017-11-28 08:47:27 +01:00
Gunnar Morling
bc2d0e5956
DBZ-464 Removing unused method parameters from AbstractDatabaseHistory#recoverRecords()
2017-11-28 08:47:27 +01:00
Jiri Pechanec
20a2cdfdea
DBZ-476 Doubled quotes are parsed as escaped
2017-11-23 14:51:51 +01:00
Jiri Pechanec
57e7f84163
DBZ-479 Forced fsync slows down tests
2017-11-22 14:34:59 +01:00
Gunnar Morling
2b3276be1d
DBZ-478 Correctly handling null value converters;
...
* using simple for loop for the sake of easier debugging
* log info about unsupported column type on WARN rather than TRACE level
2017-11-22 09:43:10 +01:00
David Szabo
1c07ff4775
DBZ-466 Remove hardcoding of schema version number, leaving it empty instead
2017-11-16 17:43:14 +01:00