qyf404

/**
* 这是个可选项, 用来添加一些自定义tag
*/
@Bean
public MeterRegistryCustomizer<MeterRegistry> metricsCommonTags(RcConfig rcConfig) {
    return registry -> registry.config()
            .commonTags("appname", "myapp",
                        "nodename", "007");
}

qyf404

import static org.junit.Assert.assertThat;
import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasKey;
import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasValue;
import static org.springframework.kafka.test.utils.KafkaTestUtils.getSingleRecord;

import java.util.Map;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.common.serialization.Deserializer;

qyf404

import static org.junit.Assert.assertThat;
import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasKey;
import static org.springframework.kafka.test.hamcrest.KafkaMatchers.hasValue;
import static org.springframework.kafka.test.utils.KafkaTestUtils.getSingleRecord;

import java.util.Map;
import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.common.serialization.Deserializer;

qyf404

build_images:
  stage: build_images
  image: docker
  services:
    - docker:dind
  variables:
    DOCKER_DRIVER: overlay2
  before_script:
    - docker info
  script:

qyf404

version: '2'
services:
  namenode:
    image: uhopper/hadoop-namenode:2.7.2
    hostname: namenode
    container_name: namenode
    domainname: hadoop
    ports:
      - 50070:50070
    volumes: