yangl

// 限制：消费组必须是存储在__offset主题中存活的，不然不会生产checkpoint从而导致没法转换！

RemoteClusterUtils.translateOffsets(new MirrorSourceConfig(props).targetAdminConfig("ROLE_ID"), sourceClusterAlias, "消费组ID", Duration.ofSeconds(10));

OffsetSyncStore

OptionalLong translateDownstream(String group, TopicPartition sourceTopicPartition, long upstreamOffset) {
        if (!readToEnd) {

yangl

allprojects {
    repositories {
        maven {
            allowInsecureProtocol = true
            url = 'https://maven.aliyun.com/repository/public'

        }

        def REPOSITORY_URL = 'https://maven.aliyun.com/repository/public/'
        //做一些国外不稳定的地址连接的替换

yangl

java -XshowSettings:system -version

Operating System Metrics:
    Provider: cgroupv1
    Effective CPU Count: 16
    CPU Period: 100000us
    CPU Quota: 1600000us

yangl

spring-javaformat https://github.com/spring-io/spring-javaformat

pom.xml

<build>
	<plugins>
		<plugin>
			<groupId>io.spring.javaformat</groupId>
			<artifactId>spring-javaformat-maven-plugin</artifactId>
 0.0.41

yangl

1. 添加依赖

<build>
        <plugins>
            <plugin>
                <groupId>io.github.git-commit-id</groupId>
                <artifactId>git-commit-id-maven-plugin</artifactId>
                <version>7.0.0</version>
                <executions>
                    <execution>

yangl

满足如下三点即可：

1. mysql的jdbc链接确保有配置connectionTimeZone及forceConnectionTimeZoneToSession=true；
2. springboot启动前配置默认时区及local；
3. mysql-connector-j驱动使用8.0.33 注：mysql-connector-j驱动8.0.23之前版本有时区bug。

CREATE TABLE `date_time_ts` (
	`long1` BIGINT(20) NULL DEFAULT NULL,
	`string1` VARCHAR(50) NULL DEFAULT NULL COLLATE 'utf8mb4_bin',

yangl

查找实现IMessageConsumeListener IStringMessageConsumeListener IConsumerListener IByteArrayMessageConsumeListener的java类问题

grep -rl --include=*.java -e "implements * IMessageConsumeListener" -e "implements * IStringMessageConsumeListener" -e "implements * IConsumerListener" -e "implements * IByteArrayMessageConsumeListener" .

yangl

#! /bin/sh

APP_NAME="SonarQube"

# Location of the pid file.
PIDDIR="${PIDDIR-.}"

# By default, java from the PATH is used, except if SONAR_JAVA_PATH env variable is set
findjava() {
  if [ -z "${SONAR_JAVA_PATH}" ]; then