Kafka Streamを使ã£ãŸã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®æ¦‚è¦ã¨é‹ç”¨æ™‚ã®è€ƒæ…®ç‚¹ - joker1007’s diary最近ã€ä»•äº‹ã§åˆ†æ•£ã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã«æ‰‹ã‚’出ã—ã¦ã„ã¦ã€ãã®åŸºç›¤ã¨ã—ã¦Apache Kafkaã¨Kafka Streamsを使ã†ã“ã¨ã«ã—ãŸã®ã§ã€å‹•ä½œæ¦‚è¦ã¨ã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã®ã‚¤ãƒ¡ãƒ¼ã‚¸ã«ã¤ã„ã¦ã¾ã¨ã‚ã¦ãŠã。 kafkaãã®ã‚‚ã®ã«ã¤ã„ã¦ã¯ä»Šæ›´èª¬æ˜Žã®å¿…è¦ã¯ç„¡ã„ã ã‚ã†ã¨æ€ã†ã€‚ Kafka Streamsã¯kafkaを基盤ã«ã—ã¦åˆ†æ•£ã‚¹ãƒˆãƒªãƒ¼ãƒ 処ç†ã‚’ç°¡å˜ã«æ›¸ããŸã‚ã®DSLライブラリ。 https://kafka.apache.org/documentation/streams/ 延々æµã‚Œã¦ãるデータを変æ›ã—ã¦åˆ¥ã®topicã«æµã—ãŸã‚Šã€æ™‚é–“ã®ã‚¦ã‚¤ãƒ³ãƒ‰ã‚¦ã‚’区切ã£ã¦ã‚«ã‚¦ãƒ³ãƒˆã—ãŸçµæžœã‚’æµã—ãŸã‚Šã€ã¿ãŸã„ãªã®ãŒã‚µã‚¯ã£ã¨æ›¸ã‘る。 Apache Flinkãªã‚“ã‹ã¨ä¼¼ãŸæ§˜ãªã“ã¨ãŒã§ãる。 Kafka StreamsãŒè‰¯ã„ã®ã¯ä»¥ä¸‹ã®ç‚¹ã€‚ ãŸã ã®Consumer/Producerã®ãƒ©ãƒƒãƒ‘ーãªã®ã§fat-jarファイル一ã¤ã§ç°¡å˜ã«å‹•ã‹ã›
Apache Kafkaã«å…¥é–€ã—ãŸ
{{#tags}}- {{label}}
{{/tags}}