You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ew...@apache.org on 2018/05/29 23:37:58 UTC
[kafka] branch trunk updated (4943c3f -> fffb9c5)
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.