일 | 월 | 화 | 수 | 목 | 금 | 토 |
---|---|---|---|---|---|---|
1 | 2 | 3 | 4 | 5 | 6 | 7 |
8 | 9 | 10 | 11 | 12 | 13 | 14 |
15 | 16 | 17 | 18 | 19 | 20 | 21 |
22 | 23 | 24 | 25 | 26 | 27 | 28 |
29 | 30 |
- RabbitMQ
- scala
- reactive
- spring-batch
- gradle
- spring-cloud-stream
- avo
- 한빛미디어
- kafkastreams
- confluent
- kafkastream
- aws
- play framework
- 플레이 프레임워크
- statestore
- Slick
- Elk
- Spring
- kafka streams
- Logstash
- Elasticsearch
- kafka interactive query
- enablekafkastreams
- spring-kafka
- springboot
- schema registry
- coursera
- 카프카
- Kafka
- scala 2.10
- Today
- Total
목록2018/04 (3)
b
GenericRecordFile/String 기반의 Schema 에서 Avro Object를 생성하는 것을 말한다. 이 방법은 runtime 에서 실패할 수 있기 때문에 사용에서는 추천되는 방법은 아니지만, 쉽게 사용 할 수 있는 장점이 있다. Schema{ "type": "record", "namespace": "com.example", "name": "user", "fields": [ { "name": "name", "type": "string" } ] }다시피 GenericRecordBuilder builder = new GenericRecordBuilder(schemaString); builder.set("name", "bistros"); GenericData.Record bistros = bui..
어제의 이슈 StreamsBuilder.table은 과연 changelog topic을 만드는가 ?https://kafka.apache.org/11/javadoc/org/apache/kafka/streams/StreamsBuilder.html#table-java.lang.String- 문서상에 의하면 '쿼리 불가능한 내부 store-name을 만들고, internal changelog topic은 만들어 지지 않는다고 한다.The resulting KTable will be materialized in a local KeyValueStore with an internal store name. Note that store name may not be queriable through Interactive Q..
Spring 4.X 에서 Conditional.... 시리즈의 어노테이션이 추가 되면서 다양한 환경에서 Bean을 등록 할 수 있게 되었다. 현재 작업중인 Event Driven MSA (이름 참 길다...) 의 한 프로젝트에서는 상용과, 개발서버의 Bean이 달라야 하는 니즈가 있다. @Configuration @EnableConfigurationProperties(SolProperties.class) public class SolAutoConfiguration { private SolProperties solProperties; @Autowired public SolAutoConfiguration(SolProperties solProperties) { this.solProperties = solPro..