Kafka
Kafkaã®ã‚³ãƒ³ã‚·ãƒ¥ãƒ¼ãƒžã‚°ãƒ«ãƒ¼ãƒ—ã«ã€ã‚³ãƒ³ã‚·ãƒ¥ãƒ¼ãƒžã‚’è¿½åŠ ã™ã‚‹ã¨ã€å„コンシューマãŒã©ã®ãƒ‘ーティションをèªã¿å–ã‚‹ã‹å†å‰²ã‚Šå½“ã¦ã™ã‚‹ãƒªãƒãƒ©ãƒ³ã‚¹ãŒè¡Œã‚れる。Kafka0.11.0.1を対象ã«ã€ä»¥ä¸‹ã®è¦³ç‚¹ã§Kafkaã®å®Ÿè£…を調ã¹ã¦ã¿ãŸçµæžœã‚’ã¾ã¨ã‚る。 リãƒãƒ©ãƒ³ã‚¹ã¯ã„ã¤è¡Œã‚れる…
Kafkaコンシューマã®ç›£è¦–ã—ãŸæ–¹ãŒè‰¯ã„メトリクスã¨ã—ã¦ã€datadog*1ã®ãƒ‰ã‚ュメントやã€Hortonworkã«ã‚ˆã‚‹Kafkaã®ãƒ™ã‚¹ãƒˆãƒ—ラクティス*2ã§ã¯records-lagãŒç´¹ä»‹ã•ã‚Œã¦ã„る。ã“ã®ã‚³ãƒ³ã‚·ãƒ¥ãƒ¼ãƒžã®lagã¨ã¯å…·ä½“çš„ã«ã©ã®ã‚ˆã†ã«è¨ˆç®—ã•ã‚ŒãŸå€¤ã‹ã€ä»¥é™ã«ã¾ã¨ã‚る。以下ã®å†……
Kafkaã®ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸ãƒã‚¹ãƒˆã®åŽŸå› ã®1ã¤ã«ã€ãƒ—ãƒãƒ‡ãƒ¥ãƒ¼ã‚µã®è¨å®šã®retries(デフォルト0:リトライã—ãªã„)ã®æœªè¨å®šãŒã‚る。 Kafkaクライアントã®é€ä¿¡ãƒªãƒˆãƒ©ã‚¤ プãƒãƒ‡ãƒ¥ãƒ¼ã‚µã‹ã‚‰ãƒ¡ãƒƒã‚»ãƒ¼ã‚¸é€ä¿¡æ™‚ã®ã‚¨ãƒ©ãƒ¼ã«ã¯ã€retiresè¨å®šã«ã‚ˆã‚ŠKafkaã®ã‚¯ãƒ©ã‚¤ã‚¢ãƒ³ãƒˆãƒ©ã‚¤ãƒ–ラリ内ã§â€¦
