Kafka Consumer 0.9 ã®æŒ™å‹•Apache Kafka 0.9.0より新ã—ã„Consumer実装ãŒè¿½åŠ ã•ã‚Œã¾ã—ãŸã€‚Brokerå´ã®å®Ÿè£…自体ã¯v0.8.2ã§æ—¢ã«è¿½åŠ ã•ã‚Œã¦ã„ã¾ã—ãŸãŒã€å…¬å¼å®Ÿè£…ã¨ã—ã¦org.apache.kafka.clients.consumer.KafkaConsumerãŒåŒæ¢±ã•ã‚Œã‚‹ã‚ˆã†ã«ãªã‚Šã¾ã—ãŸã€‚ æ–°ã—ã„APIを用ã„ãŸConsumerã¯Offsetã®ç®¡ç†ã¨ConsumerGroupã«ç´ã¥ãConsumerã®ç®¡ç†ã‚’Brokerå´ã§è¡Œã£ã¦ãれるよã†ã«ãªã‚Šã¾ã™ã€‚詳細ã«é–¢ã—ã¦ã¯Kafkaã®wikiã«è©³ã—ãã¾ã¨ã‚られã¦ã„ã¾ã™ã€‚ãŒã€æ›´æ–°ã•ã‚Œã¦ã„ãªã„資料ãŒå¤šã実際ã®ãƒ•ãƒãƒ¼ã¨ç•°ãªã£ã¦ã„る所ãŒå¤šã„ã®ã§ã€å®Ÿè£…ベースã§ç¾åœ¨ã®Consumerã®ãƒ•ãƒãƒ¼ã«ã¤ã„ã¦ç¢ºèªã—ã¦ã„ãã¾ã™ã€‚ 起動時ã®å‡¦ç† 1. Brokerã®ã‚¯ãƒ©ã‚¹ã‚¿ã®ã€ã„ãšã‚Œã‹1ã¤ã®ã‚µãƒ¼ãƒãƒ¼ã¸æŽ¥ç¶šã‚’試ã¿ã‚‹ã€‚ 起動時ã«æ¸¡ã•ã‚ŒãŸBrokerã®æŽ¥ç¶šå…ˆã®ä¸ã‹ã‚‰ã€ãƒ©ãƒ³ãƒ€ãƒ ã«1ã¤ã®
Apache Kafkaã«å…¥é–€ã—ãŸ
{{#tags}}- {{label}}
{{/tags}}