This is an automated email from the ASF dual-hosted git repository.
ewencp pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 4943c3f MINOR: reduce commit time on test (#5095)
add fffb9c5 KAFKA-6913: Add Connect converters and header converters for short, integer,
long, float, and double (KIP-305)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/storage/DoubleConverter.java} | 34 +++----
.../kafka/connect/storage/FloatConverter.java} | 34 +++----
.../kafka/connect/storage/IntegerConverter.java} | 34 +++----
.../kafka/connect/storage/LongConverter.java} | 33 +++----
.../{StringConverter.java => NumberConverter.java} | 77 ++++++++-------
.../connect/storage/NumberConverterConfig.java} | 17 ++--
.../kafka/connect/storage/ShortConverter.java} | 34 +++----
.../kafka/connect/storage/DoubleConverterTest.java | 35 +++----
.../kafka/connect/storage/FloatConverterTest.java | 35 +++----
.../connect/storage/IntegerConverterTest.java | 29 +++---
.../kafka/connect/storage/LongConverterTest.java | 28 +++---
.../kafka/connect/storage/NumberConverterTest.java | 105 +++++++++++++++++++++
.../kafka/connect/storage/ShortConverterTest.java | 36 +++----
13 files changed, 295 insertions(+), 236 deletions(-)
copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/DoubleConverter.java} (53%)
copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/FloatConverter.java} (53%)
copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/IntegerConverter.java} (52%)
copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/LongConverter.java} (53%)
copy connect/api/src/main/java/org/apache/kafka/connect/storage/{StringConverter.java =>
NumberConverter.java} (54%)
copy connect/{runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java
=> api/src/main/java/org/apache/kafka/connect/storage/NumberConverterConfig.java} (66%)
copy connect/{transforms/src/main/java/org/apache/kafka/connect/transforms/util/SchemaUtil.java
=> api/src/main/java/org/apache/kafka/connect/storage/ShortConverter.java} (53%)
copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/DoubleConverterTest.java
(57%)
copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/FloatConverterTest.java
(57%)
copy clients/src/main/java/org/apache/kafka/common/security/auth/SslAuthenticationContext.java
=> connect/api/src/test/java/org/apache/kafka/connect/storage/IntegerConverterTest.java
(58%)
copy streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDbKeyValueBytesStoreSupplier.java
=> connect/api/src/test/java/org/apache/kafka/connect/storage/LongConverterTest.java (58%)
create mode 100644 connect/api/src/test/java/org/apache/kafka/connect/storage/NumberConverterTest.java
copy streams/src/test/java/org/apache/kafka/test/KTableValueGetterStub.java => connect/api/src/test/java/org/apache/kafka/connect/storage/ShortConverterTest.java
(57%)
--
To stop receiving notification emails like this one, please contact
ewencp@apache.org.
|