This is an automated email from the ASF dual-hosted git repository.
magang pushed a change to branch realtime-streaming
in repository https://gitbox.apache.org/repos/asf/kylin.git.
from 8b374c5 Minor, fix rat check failed
new 812803c KYLIN-3744 Add configuration and fix bugs
new 74655f1 KYLIN-3821 Add consume lag stats
The 7561 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../org/apache/kylin/common/KylinConfigBase.java | 12 +++
.../kylin/rest/service/StreamingV2Service.java | 16 ++++
.../kylin/stream/coordinator/Coordinator.java | 30 +++++--
.../coordinator/client/HttpCoordinatorClient.java | 15 ++--
.../kylin/stream/coordinator/CoordinatorTest.java | 1 +
.../core/client/HttpReceiverAdminClient.java | 3 +-
.../stream/core/consumer/IStreamingConnector.java | 95 +++++++++++-----------
.../core/consumer/StreamingConsumerChannel.java | 23 +++---
.../stream/core/model/stats/ConsumerStats.java | 11 +++
.../core/model/stats/PartitionConsumeStats.java | 10 +++
.../kylin/stream/core/source/IStreamingSource.java | 5 ++
.../core/storage/StreamingSegmentManager.java | 6 +-
.../columnar/compress/LZ4CompressorTest.java | 7 +-
.../apache/kylin/stream/core/util/RestService.java | 2 +-
.../kylin/stream/server/StreamingServer.java | 6 +-
.../kylin/stream/source/kafka/KafkaSource.java | 56 +++++++++++--
.../source/kafka/consumer/KafkaConnector.java | 11 ++-
17 files changed, 223 insertions(+), 86 deletions(-)
