Configure

LOKI is very easy to configure, we just need some simple configuration！

Make sure you have LOKI installed, if you haven't, check out the Install。

RocketMQ

Configure the LokiMapperScan annotation

@LokiMapperScan
@SpringBootApplication
public class LokiTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(LokiTestApplication.class, args);
    }

}

application.yml Configure mq connection parameters

loki:
  global-config:
    mq-config:
      mq-type: rocket_mq
      address: 127.0.0.1:8081
      auth: false
      username: un
      password: ps
      connect-timeout: 300

Generally speaking, a general simple project can be used normally with the above configuration LOKI, please refer to the following project: loki-test。

Kafka

Configure the LokiMapperScan annotation

@LokiMapperScan
@SpringBootApplication
public class LokiTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(LokiTestApplication.class, args);
    }

}

application.yml Configure mq connection parameters

Supports all configurations under spring.kafka

spring:
  kafka:
    bootstrap-servers: 127.0.0.1:9092
    consumer:
      auto:
        offset:
          reset: earliest
      auto-commit-interval: 1000
      enable-auto-commit: true
      
loki:
  global-config:
    mq-config:
      mq-type: kafka
      address: 127.0.0.1:9092 

Generally speaking, a general simple project can be used normally with the above configuration LOKI, please refer to the following project: loki-test。

Redis

Configure the LokiMapperScan annotation

@LokiMapperScan
@SpringBootApplication
public class LokiTestApplication {

    public static void main(String[] args) {
        SpringApplication.run(LokiTestApplication.class, args);
    }

}

application.yml Configure mq connection parameters

Support Redis Standalone, Cluster, and Sentinel modes

Support all configurations under spring.data.redis

The configuration under mq-config will overwrite the configuration under spring.data.redis

spring:
  data:
    redis:
      host: 127.0.0.1
      port: 6379
      database: 12
loki:
  global-config:
    mq-config:
      mq-type: redis 
      address: 127.0.0.1:6379
      auth: true
      password: 123456

spring:
  data:
    redis:
      cluster:
        nodes: 
        - 127.0.0.1:6380
        - 127.0.0.1:6379
        - 127.0.0.1:6381
      password: 123456
      database: 12
loki:
  global-config:
    mq-config:
      mq-type: redis 
      address: 127.0.0.1:6380,127.0.0.1:6379,127.0.0.1:6381
      auth: true
      password: 123456

spring:
  data:
    redis:
      sentinel:
        master: mymaster
        nodes:
          - 127.0.0.1:26380
          - 127.0.0.1:26329
          - 127.0.0.1:26381
        password: 123456
      password: 123456
      database: 12
loki:
  global-config:
    mq-config:
      mq-type: redis 
      address: mymaster,127.0.0.1:26380,127.0.0.1:26379,127.0.0.1:26381
      auth: true
      password: 123456

Optional Clients

The jedis client is used by default, v1.2.0 or above, spring-data-redis is used by default when spring-data-redis is introduced, and the client can be specified via configuration parameters.

• jedis default implementation

loki:
  redis:
    support-type: default

• spring-data implementation

loki:
  redis:
    support-type: spring-data

Generally speaking, a general simple project can be used normally with the above configuration LOKI, please refer to the following project: loki-test。