Kafkaã‚’Dockerã®å¤–ã‹ã‚‰å©ã‘ãªã„ã¨ãã«ç¢ºèªã™ã¹ãè¨å®š - ã‚Šã‚“ã”ã¨ãƒãƒŠãƒŠ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を利用ã—ãŸã‚¸ãƒ§ãƒ–ã‚ューライブラリ「Decatonã€ã®æ´»ç”¨äº‹ä¾‹
{{#tags}}- {{label}}
{{/tags}}