SIGN IN SIGN UP
apache / rocketmq UNCLAIMED

Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.

#
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to You under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
RULES_JVM_EXTERNAL_TAG = "4.2"
RULES_JVM_EXTERNAL_SHA = "cd1a77b7b02e8e008439ca76fd34f5b07aecb8c752961f9640dea15e9e5ba1ca"
http_archive(
name = "rules_jvm_external",
sha256 = RULES_JVM_EXTERNAL_SHA,
strip_prefix = "rules_jvm_external-%s" % RULES_JVM_EXTERNAL_TAG,
url = "https://github.com/bazelbuild/rules_jvm_external/archive/%s.zip" % RULES_JVM_EXTERNAL_TAG,
)
load("@rules_jvm_external//:repositories.bzl", "rules_jvm_external_deps")
rules_jvm_external_deps()
load("@rules_jvm_external//:setup.bzl", "rules_jvm_external_setup")
rules_jvm_external_setup()
load("@rules_jvm_external//:defs.bzl", "maven_install")
maven_install(
artifacts = [
"junit:junit:4.13.2",
"com.alibaba:fastjson:1.2.76",
"com.alibaba.fastjson2:fastjson2:2.0.59",
"org.hamcrest:hamcrest-library:1.3",
"io.netty:netty-all:4.1.65.Final",
"org.assertj:assertj-core:3.22.0",
"org.mockito:mockito-core:3.10.0",
[ISSUE #6023] Add a unit test to verify new register process in broker with controller mode (#6024) * refactor: simplify getPID (#5962) * [ISSUE #5923] Add example tiered storage backend service provider (#5926) * implement example file segment * add metrics * add readme * fix license * fix tests * fix links in README.md * add comment to PosixFileSegment and mark as experimental * fix test * optimize image quality * Remove the useless exception class: MQRedirectException #5963 * [ISSUE #5965] Fix lmqTopicQueueTable initialization (#5968) * [ISSUE #5965] Fix lmqTopicQueueTable initialization * [ISSUE #5965] Fix lmqTopicQueueTable initialization * [ISSUE #5890] Fix dledger logging (#5959) * Fix dledger logging * Add bridge into store module * [ISSUE #5860] Set the value of order when create or update topic (#5861) * [ISSUE #5939]Adjust the MQClientInstance#sendHeartbeatToAllBroker catch code block log print level from info to warn (#5940) * [ISSUE #5924] Optimize UtilAll#sleep method (#5925) * [ISSUE #5924]Optimize UtilAll#sleep method * polish code * [ISSUE #5986] optimize the BrokerOuterAPITest class code Co-authored-by: zhouyunpeng <2474138779@qq.com> * [ISSUE #5971] Make the internal logs related to the dledger in the controller print to a file separately (#5972) * Make the internal logs related to the dledger in the controller print to a file separately * Make the internal logs related to the dledger in the controller print to a file separately * [ISSUE #5969] Remvoe duplicate deleteUnusedStats in admin processor (#5973) * [ISSUE #5847] Add checkBlock for hasMsgFromQueue * [ISSUE #5983] Make consumer support flow control code better (#5984) * When encountering the flow control code, pull it after 20ms instead of 3s * When encountering the flow control code, pull it after 20ms instead of 3s * [ISSUE #5896] feat:add pop consumer example (#5991) * feat:add pop consumer * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * Update example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java Co-authored-by: Oliver <wqdyxnbd@163.com> * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix * feat:fix --------- Co-authored-by: mahaitao617 <mahaitao617@mahaitao617deMacBook-Pro.local> Co-authored-by: Oliver <wqdyxnbd@163.com> * [ISSUE #5942] Fix the produce count include the quantity of the system topic(#5943) * [ISSUE #5999] Fix the TopicQueueMappingUtils comments typo (#6000) * [ISSUE #5996] Optimize the RemotingSerializable class code (#5998) * simplified RemotingSerializable null check * optimize the RemotingSerializable class code * [ISSUE #5994] [RIP-46] add pop and timer metrics (#5995) * add pop and timer metrics * fix according to review comment * test(broker): add ReplicasManagerRegisterTest to test the register process 1. add ReplicasManagerRegisterTest to test the register process * chore(pom): modify pom.xml to replace mockito with powermock 1. modify pom.xml to replace mockito with powermock * build(bazel): export powermock in bazel 1. export powermock in bazel --------- Co-authored-by: Xinda <xdshent@gmail.com> Co-authored-by: SSpirits <admin@lv5.moe> Co-authored-by: loboxu <loboxu@tencent.com> Co-authored-by: pingww <pingw002@gmail.com> Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com> Co-authored-by: Slideee <yechun@corp.netease.com> Co-authored-by: mxsm <ljbmxsm@gmail.com> Co-authored-by: hardyfish <85128645+hardyfish@users.noreply.github.com> Co-authored-by: zhouyunpeng <2474138779@qq.com> Co-authored-by: rongtong <jinrongtong5@163.com> Co-authored-by: zhiliatom <87265072+zhiliatom@users.noreply.github.com> Co-authored-by: zhouxiang <zhouxiang.zzx@alibaba-inc.com> Co-authored-by: mahaitao <15828010639@163.com> Co-authored-by: mahaitao617 <mahaitao617@mahaitao617deMacBook-Pro.local> Co-authored-by: Oliver <wqdyxnbd@163.com>
2023-02-10 13:41:58 +08:00
"org.powermock:powermock-module-junit4:2.0.9",
"org.powermock:powermock-api-mockito2:2.0.9",
"org.powermock:powermock-core:2.0.9",
"com.github.luben:zstd-jni:1.5.2-2",
"org.lz4:lz4-java:1.8.0",
"commons-validator:commons-validator:1.7",
2022-09-17 15:12:23 +08:00
"org.apache.commons:commons-lang3:3.12.0",
"org.hamcrest:hamcrest-core:1.3",
"io.openmessaging.storage:dledger:0.3.2",
"net.java.dev.jna:jna:4.2.2",
"ch.qos.logback:logback-classic:1.2.10",
"ch.qos.logback:logback-core:1.2.10",
"io.opentracing:opentracing-api:0.33.0",
"io.opentracing:opentracing-mock:0.33.0",
"commons-collections:commons-collections:3.2.2",
"org.awaitility:awaitility:4.1.0",
"commons-cli:commons-cli:1.5.0",
"com.google.guava:guava:31.0.1-jre",
"org.yaml:snakeyaml:2.0",
"commons-codec:commons-codec:1.13",
"commons-io:commons-io:2.7",
"com.google.truth:truth:0.30",
"org.bouncycastle:bcpkix-jdk15on:1.69",
"com.google.code.gson:gson:2.8.9",
"com.googlecode.concurrentlinkedhashmap:concurrentlinkedhashmap-lru:1.4.2",
"org.apache.rocketmq:rocketmq-proto:2.1.1",
"com.google.protobuf:protobuf-java:3.20.1",
"com.google.protobuf:protobuf-java-util:3.20.1",
"com.conversantmedia:disruptor:1.2.10",
"org.apache.tomcat:annotations-api:6.0.53",
"com.google.code.findbugs:jsr305:3.0.2",
"org.checkerframework:checker-qual:3.12.0",
"org.reflections:reflections:0.9.11",
"org.openjdk.jmh:jmh-core:1.19",
"org.openjdk.jmh:jmh-generator-annprocess:1.19",
"com.github.ben-manes.caffeine:caffeine:2.9.3",
"io.grpc:grpc-services:1.47.0",
"io.grpc:grpc-netty-shaded:1.47.0",
"io.grpc:grpc-context:1.47.0",
"io.grpc:grpc-stub:1.47.0",
"io.grpc:grpc-api:1.47.0",
"io.grpc:grpc-testing:1.47.0",
"org.springframework:spring-core:5.3.26",
"io.opentelemetry:opentelemetry-exporter-otlp:1.29.0",
"io.opentelemetry:opentelemetry-exporter-prometheus:1.29.0-alpha",
"io.opentelemetry:opentelemetry-exporter-logging:1.29.0",
"io.opentelemetry:opentelemetry-sdk:1.29.0",
"io.opentelemetry:opentelemetry-exporter-logging-otlp:1.29.0",
"com.squareup.okio:okio-jvm:3.0.0",
"io.opentelemetry:opentelemetry-api:1.29.0",
"io.opentelemetry:opentelemetry-sdk-metrics:1.29.0",
"io.opentelemetry:opentelemetry-sdk-common:1.29.0",
"io.github.aliyunmq:rocketmq-slf4j-api:1.0.0",
"io.github.aliyunmq:rocketmq-logback-classic:1.0.0",
"org.slf4j:jul-to-slf4j:2.0.6",
"org.jetbrains:annotations:23.1.0",
"io.github.aliyunmq:rocketmq-shaded-slf4j-api-bridge:1.0.0",
[ISSUE #6154] Support Amazon S3 backend in TieredStorage (#6495) * support s3 backend in tiered storage * refactor(tieredstorage): Unify all object storage configuration properties 1. Unify all object storage configuration properties * refactor(tieredstorage): replace some lambda function with more simple expression 1. replace some lambda function with more simple expression * style(tieredstorage): perfect comments on ChunkMetadata 1. perfect comments on ChunkMetadata * refactor(tieredstorage): perfect lambda expression 1. perfect lambda expression * fix(tieredstorage): fix unmatched config attributes in brokerS3.conf 1. fix unmatched config attributes in brokerS3.conf * feat(tieredstorage): More context in logging output 1. More context in logging output * fix(tieredstorage): fix wrong concurrently put 1. fix wrong concurrently put * test(tieredstorage): add UT to verify TieredFileSegmentInputStream 1. add UT to verify TieredFileSegmentInputStream * refactor(tieredstorage): better code placement 1. better code placement * refactor(tieredstorage): refactor TieredFileSegmentInputStream for better understandability 1. refactor TieredFileSegmentInputStream for better understandability * feat(tieredstorage): support `reset` of TieredFileSegmentInputStream 1. support `reset` of TieredFileSegmentInputStream * fix(tieredstorage): fix wrong position when failed in `S3FileSegment#commit0` 1. fix wrong position when failed in `S3FileSegment#commit0` * fix(tieredstorage): fix still have upload buffer when already seal the segment 1. fix still have upload buffer when already seal the segment * test(tieredstorage): fix wrong assertion 1. fix wrong assertion * feat(tieredstorage): support switch to enable merge chunks into segment 1. support switch to enable merge chunks into segment * feat(tieredstorage): add more debug log in TieredMessageStore 1. add more debug log in TieredMessageStore * style(tieredstorage): use rmq code style 1. use rmq code style * feat(tieredstorage): add metrics for S3 provider 1. add metrics for S3 provider * fix(tieredstorage): resolve conflicts after rebasing master 1. resolve conflicts after rebasing master Closes https://github.com/apache/rocketmq/issues/6624 * style(tieredstorage): change log level 1. change log level Closes https://github.com/apache/rocketmq/issues/6154 * build(controller): build tieredstorage with bazel 1. build tieredstorage with bazel * build(controller): build tieredstorage with bazel 1. build tieredstorage with bazel * style(tieredstorage): change log level 1. change log level Closes https://github.com/apache/rocketmq/issues/6154 * test(tieredstorage): ignore tests about S3Mock 1. ignore tests about S3Mock * test(tieredstorage): ignore tests about S3Mock 1. ignore tests about S3Mock
2023-06-07 13:07:51 +08:00
"software.amazon.awssdk:s3:2.20.29",
"com.fasterxml.jackson.core:jackson-databind:2.13.4.2",
"com.adobe.testing:s3mock-junit4:2.11.0",
"io.github.aliyunmq:rocketmq-grpc-netty-codec-haproxy:1.0.0",
"org.apache.rocketmq:rocketmq-rocksdb:1.0.6",
"com.alipay.sofa:jraft-core:1.3.14",
"com.alipay.sofa:hessian:3.3.6",
"io.netty:netty-tcnative-boringssl-static:2.0.48.Final",
"org.mockito:mockito-junit-jupiter:4.11.0",
"com.alibaba.fastjson2:fastjson2:2.0.59",
"org.junit.jupiter:junit-jupiter-api:5.9.1",
],
fetch_sources = True,
repositories = [
# Private repositories are supported through HTTP Basic auth
"https://repo1.maven.org/maven2",
],
)
http_archive(
name = "io_buildbuddy_buildbuddy_toolchain",
sha256 = "b12273608db627eb14051eb75f8a2134590172cd69392086d392e25f3954ea6e",
strip_prefix = "buildbuddy-toolchain-8d5d18373adfca9d8e33b4812915abc9b132f1ee",
urls = ["https://github.com/buildbuddy-io/buildbuddy-toolchain/archive/8d5d18373adfca9d8e33b4812915abc9b132f1ee.tar.gz"],
)
load("@io_buildbuddy_buildbuddy_toolchain//:deps.bzl", "buildbuddy_deps")
buildbuddy_deps()
load("@io_buildbuddy_buildbuddy_toolchain//:rules.bzl", "buildbuddy")
buildbuddy(name = "buildbuddy_toolchain")
http_archive(
name = "bazel_skylib",
sha256 = "51b5105a760b353773f904d2bbc5e664d0987fbaf22265164de65d43e910d8ac",
urls = [
"https://mirror.bazel.build/github.com/bazelbuild/bazel-skylib/releases/download/1.8.1/bazel-skylib-1.8.1.tar.gz",
"https://github.com/bazelbuild/bazel-skylib/releases/download/1.8.1/bazel-skylib-1.8.1.tar.gz",
],
)
load("@bazel_skylib//:workspace.bzl", "bazel_skylib_workspace")
bazel_skylib_workspace()
http_archive(
name = "rules_java",
urls = [
"https://github.com/bazelbuild/rules_java/releases/download/7.12.5/rules_java-7.12.5.tar.gz",
],
sha256 = "17b18cb4f92ab7b94aa343ce78531b73960b1bed2ba166e5b02c9fdf0b0ac270",
)
load("@rules_java//java:repositories.bzl", "rules_java_dependencies", "rules_java_toolchains")
rules_java_dependencies()
rules_java_toolchains()
load("@rules_java//toolchains:local_java_repository.bzl", "local_java_repository")
local_java_repository(
name = "jdk8",
version = "8",
java_home = "/usr/lib/jvm/java-8-openjdk-amd64",
)