anny0739

<source>
  @type kafka_group
  brokers "#{ENV['KAFKA_BROKERS']}"
  consumer_group "#{ENV['KAFKA_CONSUMER_GROUP']}"
  topics "#{ENV['KAFKA_TOPIC']}"
</source>

<filter search>
  @type mysql_json
</filter>

anny0739

spring.profiles: local
app:
  url: localhost:8801
---
spring.profiles: dev
app:
  url: dev:8801
---
spring.profiles: stage
app:

anny0739

spring:
  application:
    name: app_name
  profiles:
    active: local
aws:
  secretsmanager:
    name: app_name
cloud:
  aws:

anny0739

import javax.crypto.Mac
import javax.crypto.spec.SecretKeySpec
import kotlin.experimental.and


fun main(args: Array<String>) {

  val hmacFromKomoju = "06cb40bd7c630613e41f874296eddd0153d023857a76a9de52daad5da6c2bbe4"

  val algorithm = "HmacSHA256"

anny0739

package com.benx.weply.core.spring.jpa;
import com.benx.weply.core.SpringTest;
import com.benx.weply.core.domain.enums.Shop;
import com.benx.weply.core.domain.user.User;
import com.benx.weply.core.domain.user.UserService;
import lombok.extern.slf4j.Slf4j;
import org.hibernate.StaleObjectStateException;
import org.junit.Test;
import org.springframework.beans.factory.annotation.Autowired;
import javax.persistence.EntityManager;

anny0739

@Entity
public class Goods {
  private int goodsId;
}

@Entity
public class GoodsDetail {
  private Assertion<Goods> goodsId;
}

anny0739

  @Inject
  private RedissonClient redissonClient;
  private Exception exception;

  private final CountDownLatch latch = new CountDownLatch(2);

  @Test
  public void syncTest() {
      List<Thread> threads = IntStream.range(0, 2)
          .mapToObj(i -> new Thread1())

anny0739

@Service
public class AService {

  @Autowired
  private BService bService;
  
  public void doSomething() {
    bService.doSomething();
  }
}

anny0739

public class KubernetesLables {
  @JsonProperty("beta.kubernetes.io/arch")
  private String betaArch;
  @JsonProperty("beta.kubernetes.io/os")
  private String betaOs;
  @JsonProperty("kubernetes.io/arch")
  private String arch;
  @JsonProperty("kubernetes.io/hostname")
  private String hostname;
  @JsonProperty("kubernetes.io/os")

anny0739

public AService {
  @Autowired private ARepository repository;
  
  @Transactional
  public void save(A a) {
   repository.save(a);
   // update(a); // update 트랜잭션 적용안됨 XXX
  }
  
  @Trnasaction(propagation = Propagation.REQURIES_NEW)