Apache Kafka Meetup Japan #2 https://kafka-apache-jp.connpass.com/event/45923/ çºè¡¨è³æ

ãããé販大æã®ã¢ãã¾ã³ã¸ã£ãã³ã¯6æ¥ãå ¨å½ã®æ¸åºããã®æ³¨æã«å¿ãã¦èªç¤¾ãä»å ¥ããæ¬ãå¸ããµã¼ãã¹ã仲éå¸ãã仿ä¸ã«ãéå§ããã¨çºè¡¨ããã購買åã®å¼±ãå°æ¹ã®å°è¦æ¨¡ãªæ¸åºã«ãã¹ãã»ã©ã¼ãªã©å£²ãçã®æ¬ãå¸ããã¨ã§ãæ¶è²»è ã®ãã¼ãºã«å¹ åºãå¿ããã®ãçãã ããã ãäºå®ä¸ã®ãåãæ¬¡ããæ¥åã¸ã®åå ¥ã¨ããããããã¾ã§ã®åºçæµéã®ããæ¹ã«å½±é¿ãåºãå¯è½æ§ãããã ç¾å¨ã®åºçæµéã¯ãåºç社ã忬¡åºã«å¸ãã忬¡åºãæ¸åºã«å¸ãæ¹å¼ãä¸è¬çãããã以åãããå°æ¹ã®å°è¦æ¨¡ãªæ¸åºã«å¯¾ãã売ãçã®æ¬ã忬¡åºããªããªãå¸ããªããã¨ãåé¡ã«ãªã£ã¦ãããå社ã¯ããããåé¡ãè§£æ¶ãããã¨ãã仲éå¸ãã®å°å ¥ã決ããã¨ãããåç¤¾ã®æ å½è ã¯è¨è ä¼è¦ã§ãæ¸åºåãã®åå¼ãéå§ããããå¤ãã®èªè ã«æ¬ãå±ãã¦ãããããã¨èªã£ãã
ã¯ããã« ãããã¤æé 1.ãµã¤ã³ã¢ãã 2.appã®è¨å® 3.profileã®è¨å® 4.ããã㤠修æ£ç®æ package.jsonããªãã¸ããªã«ããã requirements.txtã使ãã python3.6â3.7ã«å¤æ´ ãªãã·ã§ã³ã®æ¸¡ãæ¹ã夿´ ããã ã¯ããã« serverlessããCI/CDã®ä¸è¬æä¾ãã¢ãã¦ã³ã¹ããã¾ããï¼ èªåã¯ç°¡åãªãããå¦çãªã©ãlambdaã§åããã¦ãããlamdbaã®æ§æç®¡çããªãªã¼ã¹ã«serverlessãå©ç¨ãã¦ããã®ã§ãæ©éCI/CDããå®è¡ãã¦ã¿ã¾ããï¼ serverless.com ãããã¤æé 1.ãµã¤ã³ã¢ãã ããã·ã¥ãã¼ãç»é¢ã«ã¢ã¯ã»ã¹ GitHubã®ã¢ã«ã¦ã³ãã§SIGN UP GitHubOAuthã§ã®èªè¨¼ãè¨±å¯ ãnextããã¯ãªã㯠ã¦ã¼ã¶ã¼åï¼ããã©ã«ãã ã¨GitHubã¦ã¼ã¶ã¼åï¼ãè¨å®ãããnextããã¯ãªã㯠ã¢ã
Dockerã§ç«ã¡ä¸ããKafkaãããã¹ãç°å¢ã§ãã«ãããJavaã¢ããªã±ã¼ã·ã§ã³ããå©ããã¨ããã®ã ãããªããã¨ã©ã¼ã«ãªã£ã¦å©ããã java.lang.IllegalStateException: No entry found for connection 21729123512 ãã調ã¹ã¦ã¿ãã¨ãadvertised_listenerã®è¨å®ãå¿ãã¦ãããã¨ã«æ°ãã¤ããã advertised_listenerã¨ã¯ Kafkaã®ã³ã¢ã§ããKafka brokerã¯Listenerãæã£ã¦ãããã¯ã©ã¤ã¢ã³ãããListenerã«æ¥ç¶ãããã¨ããã®Listenerã¯èªèº«ãã¢ã¯ã»ã¹ã§ããIPã¢ãã¬ã¹ã¾ãã¯ãã¹ãåãè¿ããããã使ã£ã¦ãã®å¾ã®å¦çãè¡ãããã ããããKafkaã¨ã¢ããªã±ã¼ã·ã§ã³ãåãç°å¢ã«ããã°å ¨ãåé¡ãªãããDockerã使ã£ã¦ããã¨ãããåé¡ã«ãªããããListener
ä»åã¯ååæ§ç¯ããï¼ã³ã³ããã§ã®Kafkaãè¤æ°ã³ã³ããã«ãã¦ã¿ãã è¤æ°ã³ã³ãããæ§æããã«ã¯ãdocker-composeãå©ç¨ããã¨ä¾¿å©ãããã ã¨ãããã¨ã§docker-composeã使ã£ã¦ã¿ãã ï¼ï¼Docker-composeã®ã¤ã³ã¹ãã¼ã« # curl -L https://github.com/docker/compose/releases/download/1.7.1/docker-compose-`uname -s`-`uname -m` > /usr/local/bin/docker-compose # chmod +x /usr/local/bin/docker-compose ï¼ï¼Docker-composeã®yamlãã¡ã¤ã«ã使ããã ä»åã¯ï¼ã¤ã³ã³ãããèµ·åããåã ã«Brokerãèµ·åããããã«ããã 以ä¸ã®æ§ãªyamlã使ããã version: '2
This tutorial provides a step-by-step instruction on how to deploy a Kafka broker with Docker containers when a Kafka producer and consumer sit on different networks. As a part of our recent Kaa enhancement we needed to deploy one of our newly created Kaa services together with a Kafka server in Docker containers and test it from a host machine. The service played the role of a Kafka producer and
$ vim ~/.aws/credentials [default] aws_access_key_id = hoge aws_secret_access_key = huga cloudfront=true [private] aws_access_key_id = hogehoge aws_secret_access_key = hugahuga service: go-hatena provider: name: aws runtime: go1.x stage: ${opt:stage, self:custom.defaultStage} #profileãªãã·ã§ã³è¿½å profile: ${opt:profile, self:custom.defaultProfile} #regionãªãã·ã§ã³è¿½å region: ${opt:region, self:custom.defaul
jsonã¨ã³ããªãæã¤ãã¡ã¤ã«ãå ¥åã¨ãã¦åãåãããã®ããªã¼æ§é ãçæããjavascriptã³ã¼ããè¨è¿°ãã¾ããã以ä¸ã¯åããã®ã®ãã£ãã«ã§ãï¼ https://jsfiddle.net/rishi007bansod/wk8nx21t/63/ 次ã®ãã¡ã¤ã«ãå ¥åã¨ãã¦ãã¹ããããã¨ãã§ãã¾ã https://jsoneditoronline.org/?id=fd7cf89cd7f3469dbcd318575a86d7cc ãã®jsonã®ãã¼ããå±é/æãããã¿ã§ããããã«ããã®ããªã¼æ§é ãæãããã¿å¯è½ã«ãã¾ãããããå®è£ ããããã«ãç§ã¯ã³ã¼ããåç §ãã¦ãã¾ãï¼ åºæ¬çãªæãããã¿å¯è½ ãã®åºæ¬çãªæãããã¿æ©è½ã使ç¨ãã¦ã¿ã¾ãããã以ä¸ã¯åãã³ã¼ãã§ãï¼ HTML <script type="text/ng-template" id="tree_item_renderer.html"
æ°å¹´ä¸çºç®ã®ã¨ã³ããªã¯å°ã æ°ãããã¨ã«ææ¦ãããã¨ãããã¨ã«ãã¾ããããããããªã§ãã ä»åã¯Elasticsearchã¨C#ã§ã®ãã°åæåºç¤ã®ä½æããã£ã¦ã¿ã¾ãã ã¾ã å®è·µçãªãã¨ã¯ä½ãã§ãã¦ããªãç¶æ ã§ãããã§ãããã¨ãå°ããã¤ããã°ã«æ®ãã¦ãããã¨æãã¾ãã (宿ãã¦ããã¨ããã£ã¦ããã¨ãæ¨å¹´æ«ã¿ããã«æ´æ°é »åº¦ãä¸ãã£ã¦ãã¾ãã¾ãã®ã§ã) ä»åå©ç¨ããããã±ã¼ã¸ãæè¡è¦ç´ ã¯ãããªæãã§ãã Elasticsearch kibana logstash docker .Net core(C#) ãªããã°åæãéè¦ã ãã°ã¨ããã®ã¯ãä½ãèµ·ããããåæããã®ã«éè¦ã§ãã ç¹ã«åé¡ãèµ·ããå ´åã«ã¯ãã°ããåæããå ´åãã»ã¨ãã©ã§ãããã¯åéãåããåãã ã¨æã£ã¦ãã¾ãã(WebãªãApacheãã°ãçµã¿è¾¼ã¿ãªãã«ã¼ãã«ãã°ã¨ã) ãã°åæã§å¾ãçµæã¯ãã¨ã³ã¸ãã¢ã»çµå¶ã©ã¡ãã«ãæ³¢åãã¦ãã
Docker-composeã§ECSä¸ã«ã³ã³ãããèµ·åãã¦ãã°åéã»åæåºç¤(ELK)ãæ§ç¯ãã ã¯ããã« å ¬éãã¦ããWebã¢ããªã±ã¼ã·ã§ã³ã®ã¢ã¯ã»ã¹ãã°ãåéãããããã°ã®åéã»åæåºç¤ã¨ãã¦ELKç°å¢ãæ§ç¯ãã¾ãããèªåã§ãµã¼ããç«ã¦ãã®ãé¢åã ã£ãã®ã§ãAWSã¨Dockerã®ãåå¼·ãã¦ããDocker-composeãã¡ã¤ã«ãç¨æãã¦ãECSä¸ã§ã³ã³ãããèµ·åããã·ã¹ãã ãæ§ç¯ãã¾ããããªããæ§ç¯æã®ã¨ã©ã¼ã»ãã©ãã«ã«ã¤ãã¦ã¯å¥è¨äºã§ã¾ã¨ãããã¨æãã¾ãã ãã®è¨äºã®å¯¾è±¡è Elasticsearch, Logstash, Kibanaç°å¢ãDockerã§æ§ç¯ããã®ãåã㦠ECSã使ã£ããã¨ããªããdocker-compose.ymlããECSä¸ã§ã³ã³ããã建ã¦ãã人 ãã®è¨äºãè¦ã¦ã§ããã㨠ECSä¸ã§docker-composeã使ã£ã¦ãã³ã³ãããèµ·åã§ãã EC2ä¸ã«ELK
åæ ãããªããµã¼ãã¼ãããã ãéãç¡ããµã¼ãã¼ãåããã®ãä¸è¦å´ãªæ¥ã ãéã£ã¦ããã¾ããRubyãªãã¦VMã ãã§50MBã¨ããããããã512MBã®åãã¦ããµã¼ãã¼ã ã¨ãã大å¤ãªãã§ããApacheã¨ããåããã¦ããããã¡ã¢ãªãç¡ããã§ããåç³åã§ã¤ã¤ã¾ããæ®ããã¦ããæãã§ãã Amazon ããã¨ããµã¼ãã¼ç¡æãã±ããã¨ããããªãããªã¼ |Ïã»`ï¼ãã© åç»ããã£ãã©ãã¦æ¥½ãããä»çµã¿ãåºæ¥ä¸ãã£ãã使ããã¦ããããããAWSã®ç¡æã¯ã¼ãã³1å¹´åã¨ããããªãããªã¼ |Ïã»ï¼ãã© |Ïã»ï¼ãã© Ubuntu ã¯ã¹ã¯ãããå²ãå½ã¦ããã¦ç¡ãã® Rubyã«ãããªãã£ã¦è¨ãããããªãã§ãããã¿ããªãã¤ãã£ãã©ã¤ãã©ãªã¼ã¨ãããããã¨ã³ã·ã¹ãã çãªãã®ãæ´»ç¨ããã¦ããã ãããã¨ããããããã¦ãã»ãã¨ã¿ããªãããã¨ãã ã¤ãã£ãå¦çãcronã§ã¾ããã¦ãããéä¸ã§æ¢ã¾ã£ã¦ã¦ãã³ãã³ãã©ã¤ã³ã§å®è¡
å æ¥ãWindows 10 PCã®ä¸ã«æ§ç¯ãããUbuntu 18.04ç°å¢ã NVIDIA SDK ManagerããJetPack 4.2ãã¤ã³ã¹ãã¼ã«ãããã¨ããã¨ããã(ä»®æ³)ã¹ãã¬ã¼ã¸ã®ç©ºã容éä¸è¶³ã§å¤±æãã¦ãã¾ãã¾ããã ã¹ãã¬ã¼ã¸ã®æ¡å¼µã¯ãVagrantã®ãã©ã°ã¤ã³ã§è¡ãããã§ãã Vagrantãã©ã°ã¤ã³ã«ã¤ãã¦æ å ±æºã®è¦æ¸ã¨ãã¹ãã¬ã¼ã¸ã®æ¡å¼µæé ãè¨é²ãããã¨æãã¾ãã Vagrantã®ã¹ãã¬ã¼ã¸æ¡å¼µæé VirtualBoxåã Vagrantã®ãã©ã°ã¤ã³ä¸è¦§ Vagrantã便å©ã«ä½¿ç¨ããã¦é ãã¨ããæ§ã ãªæ©è½ãæä¾ãã¦ä¸ããå種ãã©ã°ã¤ã³ã¯å¿ é ãã¨æãã¾ããã ãã®ãã©ã°ã¤ã³ã®ä¸è¦§ã¯ããã®ãããã«ã¾ã¨ãããã¦ããããã§ãã Available Vagrant Plugins · hashicorp-vagrant Wiki · GitHub ãã¡ããæè¦è´ãã¾ãã¨ã
Ubuntu Server 18.04 LTS ã§ã®ã¹ã¯ãããã¡ã¤ã«è¨å®ãåå¿é²ã¨ãã¦ã¾ã¨ãã¦ããããã¨æãã¾ãã ã¹ã¯ãããã¡ã¤ã«è¨å® #ã¹ã¯ããè¨å®ãç¢ºèª $ sudo cat /proc/swaps #ã¹ã¯ãããã¡ã¤ã«ã使ãããã£ã¬ã¯ããªã使 $ sudo mkdir /var/swap/ #ã¹ã¯ãããã¡ã¤ã«ã¨ãã¦ã2Mã®ãããã¯ãµã¤ãºã®ãã®ã2048åä½ã $ sudo dd if=/dev/zero of=/var/swap/swap0 bs=2M count=2048 #ãã¼ããã·ã§ã³å¤æ´ $ sudo chmod 600 /var/swap/swap0 #ã¹ã¯ãããã¡ã¤ã«ãã¹ã¯ããã«å²ãå½ã¦ã $ sudo mkswap /var/swap/swap0 $ sudo swapon /var/swap/swap0 #èµ·åæã«èªåçã«è¨å®ãããããã«ãã $ sudo nan
ãã®è¨äºãæ¸ãçç± åç´ã«æ å ±éãå°ãªãã®ã¨ãå ¬å¼ã¡ã³ãã¼ã«ãããã¹ãªã¼ãããã£ãããã å ¬å¼ã¡ã³ãã¼ã®ãã¹ãªã¼ãã£ã¦è¨ãã®ãä¸è¨URLå ã®Discussionã§ã®å ¬å¼ã¡ã³ãã¼ã®è¿çå å®¹ï¼ ãParsing csv file with dynamic headers/columnsã(ãããã¼/ã«ã©ã ãåçã«åå¾ãã¦CSVãã¡ã¤ã«ãè§£æãã) âåé¡ã®è¿ä¿¡å 容 ä»äºä¸ãåãã¦Logstashã使ããã¨ã«ãªã£ã¦èª¿ã¹ã¦ããã¨ãã«ãã®ã³ã¡ã³ãï¼ ä¿ºãä¿¡ãããããï¼åè«æãã§ä¿¡ãã¦æã¡åããã®ã¨ãã«è¨ã£ã¡ãã£ããããï¼ï¼ ãLogstsashã ã¨CSVãã¡ã¤ã«ã®ã«ã©ã åã¨ãåçã«å¤æ´ã§ããªããã£ã¦ï¼ï¼ï¼ ãã©ãå ¬å¼ããã¥ã¡ã³ãã¨ãèªã¿ãªããè²ã ã¨è©¦ããããColumnåãåçã«ã§ãã¡ãã£ãã¨ãã«ã©ãã ãå ¬å¼ã¡ã³ãã¼ã®ãã®ã³ã¡ã³ãã«ã ã«ã¤ãããï¼ï¼ï¼ï¼ ãããªãããªã§ããæ¹ã«ã¤ãã¦æ¸ããã¨ããæ°ã«ãª
Deleted articles cannot be recovered. Draft of this article would be also deleted. Are you sure you want to delete this article? ã¯ããã« O`REILLYçºè¡ã® ãã¤ã¯ããµã¼ãã¹ã¢ã¼ããã¯ã㣠ãèªã¿ã¾ããã é常ã«è峿·±ããããã¾ã§ä¸»ã«ä¼æ¥åãã¨ã³ã¿ã¼ãã©ã¤ãºéçºã«é¢ãã£ã¦ããèªåã«ã¨ã£ã¦ã¯ãä»å¾ã®ã½ããã¦ã§ã¢ã¨ã³ã¸ãã¢ã¨ãã¦ã®ãã£ãªã¢ãä½ã£ã¦ããã«ã¯ãèãæ¹ã®è»¢æãå¿ è¦ã ã¨æ°ä»ããããå 容ã§ããã æ¬æ¸ã®å 容ã¯åºç¯å²ã«æ¸¡ãã¾ãããç¹ã«éè¦ã¨æããè¦ç¹ãæ´ç(ããªãé·ãã§ãã)ãã¦ããããã¨æãã¾ããï¼å¾ç·¨ ã¨ã®2鍿§æã§ãï¼ è¦ç¹ ã¯ããã« ãã¤ã¯ããµã¼ãã¹ãåãå·»ãæè¡ã®é²æ©ã¯æ©ãããã¤ã¯ããµã¼ãã¹ãå®ç¾ããç¹å®ã®æè¡ãç¿å¾ãããã¨ãããããã®æ¬è³ªçãªèã
ãã¹ã¦ç»ååç»æ¸ç± When to use... www.kai-waehner.de When to use... www.kai-waehner.de Synchronous Request-Reply... callistaenterprise.se REST Request-Response... www.benstopford.com When to use... www.kai-waehner.de Design patterns for... stackoverflow.blog Durable request reply www.svlada.com java - How to return HTTP... stackoverflow.com Request-Reply pattern using... bvn13.medium.com Apache Kafka as an
ãã³ã³ããã®ãããã¤ãç°¡åã«ãã¾ãããï¼ãECSã®ãããã¤ãã¼ã«ã§ãããecspressoãã触ã£ã¦ã¿ã ããã«ã¡ããæå¹ã®ã¨ã·ã¨ã§ãã å æ¥ã®AWS DevDay Tokyo 2019ã¯èªåãåå åºæ¥ã¦æ¬å½ã«åå¼·ã«ãªãã¾ããã ä»åã¯çºè¡¨ãããè¤æ°ã»ãã·ã§ã³ã§åº¦ã ç»å ´ãããecspressoããæ°ã«ãªã£ãã®ã§ä½¿ç¨æãç¥ããã触ã£ã¦ã¿ã¾ããã ecspressoã¨ã¯ï¼ é¢ç½æ³äººã«ã¤ãã¯æ§ããæä¾ããã¦ããGo製ã®ECSãããã¤ãã¼ã«ã§ãã kayac/ecspresso èªã¿æ¹ã¯ãã¨ã¹ãã¬ãã½ãã¨ããããã§ãã ã¤ã³ã¹ãã¼ã«æ¹æ³(macOSã®ã¿) brew install kayac/tap/ecspresso 確èªãã¼ã¸ã§ã³ % ecspresso version ecspresso v0.11.1 ECSãµã¼ãã¹ã®ã³ã¼ãã¨ã¯ã¹ãã¼ã æåã«ãããã¨ã¨ãã¦ecspressoã§ç®¡çåºæ¥ãè¨
class: center, middle # Apache Kafka<br/>ã使ã£ã<br/>ãã¤ã¯ããµã¼ãã¹åºç¤ [2016/01/31 Scala Matsuri](https://scalamatsuri.org/)  --- class: center, middle çºè¡¨å¾ã«è¿½è¨ [彿¥ã®çºè¡¨åç»ã¯ãã¡ã](https://www.youtube.com/watch?v=64HNeksRx5I) --- class: middle <img src="image/xuwei.gif" alt="icon" width="100" height="100" /> - twitter [@xuwei_k](https://twitter.com/
REST APIã«ããè¨è¨ æè¿ã®ã·ã¹ãã ã¯æ§ã ãªããã¤ã¹ãã¹ã±ã¼ã©ããªãã£ãéè¦ãããããåã·ã¹ãã ãåå²ã軽éãªAPIã§é£æºãããã¤ã¯ããµã¼ãã¹çãªã¢ã¼ããã¯ãã£ã¹ã¿ã¤ã«ãå¢ãã¦ãã¦ãã¾ãã ããã¦ããã®API飿ºã§åºãæ¡ç¨ããã¦ããã®ããREST APIã§ãã ããããããããè¨è¨ãè¡ã£ã¦ããã«ã¯ãé©åã«èæ ®ã鏿ããªããã°ãªããªããã¨ãå¤ãããã¾ãã URLããã©ã¡ã¼ã¿ãã¨ã©ã¼ãªã©ã®è¨è¨ åè¨èªãã¨ã®ã©ã¤ãã©ãªãããµã¼ããã¯ã©ã¤ã¢ã³ãã®é¸å®ãè¨è¨ èªè¨¼ãèªå¯ ããã¥ã¡ã³ã管ç ã¦ããããã¹ããã¤ã³ãã°ã¬ã¼ã·ã§ã³ãã¹ããã¢ãã¯ãConsumer-Driven Contracts éçºç¨ãã¼ã« 絶対çã¹ã¿ã³ãã¼ãããªãç¶æ³ä¸ã§ããããã£ãåé¡ã¯ã·ã¹ãã ãã¡ã³ãã¼ãå¢ããã«ã¤ãè¤éåãã¦ãããè¨è¨ã管çããã®ä»çµã¿ä½ãã«æéãåãããæ¬æ¥ã®ç®çã¨ãªãã¹ãæ©è½éçºã®æéã失ã£ã¦ãããã¨ã«ãª
ãªãªã¼ã¹ãé害æ å ±ãªã©ã®ãµã¼ãã¹ã®ãç¥ãã
ææ°ã®äººæ°ã¨ã³ããªã¼ã®é ä¿¡
j次ã®ããã¯ãã¼ã¯
kåã®ããã¯ãã¼ã¯
lãã¨ã§èªã
eã³ã¡ã³ãä¸è¦§ãéã
oãã¼ã¸ãéã
{{#tags}}- {{label}}
{{/tags}}