You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by xv...@apache.org on 2021/01/09 00:05:01 UTC
[druid] branch master updated (2837a9b -> 118b501)
This is an automated email from the ASF dual-hosted git repository.
xvrl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 2837a9b [Minor Doc Fix] Correct the default value of `druid.server.http.gracefulShutdownTimeout` (#10661)
add 118b501 Introduce KafkaRecordEntity to support Kafka headers in InputFormats (#10730)
No new revisions were added by this update.
Summary of changes:
.../org/apache/druid/data/input/InputEntity.java | 3 +
.../druid/data/input/kafka/KafkaRecordEntity.java | 53 +++++
.../IncrementalPublishingKafkaIndexTaskRunner.java | 13 +-
.../druid/indexing/kafka/KafkaIndexTask.java | 5 +-
.../druid/indexing/kafka/KafkaRecordSupplier.java | 10 +-
.../indexing/kafka/supervisor/KafkaSupervisor.java | 9 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 256 ++++++++++++++++++---
.../indexing/kafka/KafkaRecordSupplierTest.java | 26 ++-
.../kafka/supervisor/KafkaSupervisorTest.java | 3 +-
.../druid/indexing/kinesis/KinesisIndexTask.java | 5 +-
.../indexing/kinesis/KinesisIndexTaskRunner.java | 9 +-
.../indexing/kinesis/KinesisRecordSupplier.java | 61 +++--
.../kinesis/supervisor/KinesisSupervisor.java | 9 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 106 +++++----
.../kinesis/KinesisRecordSupplierTest.java | 38 +--
.../indexing/kinesis/KinesisSamplerSpecTest.java | 13 +-
.../kinesis/supervisor/KinesisSupervisorTest.java | 3 +-
.../seekablestream/RecordSupplierInputSource.java | 16 +-
.../seekablestream/SeekableStreamIndexTask.java | 11 +-
.../SeekableStreamIndexTaskRunner.java | 28 +--
.../seekablestream/SeekableStreamSamplerSpec.java | 6 +-
.../indexing/seekablestream/SequenceMetadata.java | 12 +-
.../indexing/seekablestream/StreamChunkParser.java | 14 +-
.../common/OrderedPartitionableRecord.java | 25 +-
.../seekablestream/common/RecordSupplier.java | 5 +-
.../supervisor/SeekableStreamSupervisor.java | 21 +-
.../overlord/sampler/InputSourceSamplerTest.java | 35 +--
.../RecordSupplierInputSourceTest.java | 11 +-
.../SeekableStreamIndexTaskTestBase.java | 48 +++-
.../seekablestream/StreamChunkParserTest.java | 13 +-
.../SeekableStreamSupervisorStateTest.java | 17 +-
31 files changed, 593 insertions(+), 291 deletions(-)
create mode 100644 extensions-core/kafka-indexing-service/src/main/java/org/apache/druid/data/input/kafka/KafkaRecordEntity.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org