'2019/04/09'에 해당되는 글 2건

  1. 2019.04.09 [kafka] 읽은 부분부터 보기
  2. 2019.04.09 [debezium] Decimal(15,1)

 

sudo /usr/local/confluent-5.1.2/bin/kafka-avro-console-consumer  --bootstrap-server  서버목록      --property print.key=true     --property schema.registry.url=스키마-리지스트리 --topic user --consumer.config /home/www/consumer.properties

 consumer에서 맨 마지막 읽은 부분부터 읽고 싶으면 다음 설정을 적용한다.

<consumer.propertie>

auto.offset.reset=latest
group.id=usergroup



정말 잘 설명된 문서

https://free-strings.blogspot.com/2016/04/blog-post_27.html

https://docs.confluent.io/current/clients/consumer.html

https://kafka.apache.org/documentation/

Posted by '김용환'
,

decimal.handling.mode의 기본 모드는 precise로서 Bas64인코딩 정보를 kafka에 전달한다.
string으로 변경하면 문자로 제대로 잘 저장하기에 정밀도 이슈, BigDecimal 이슈를 모두 해결한다.

"decimal.handling.mode": "string",

 

0.9.1 버전에서는 mysq의 decimal 타입일 때 exception이 발생했었는데. 

0.9.2 버전과 "decimal.handling.mode": "string",를 추가하면 괜찮을 듯 싶다.

Posted by '김용환'
,