Apache คาฟคา มีความคล้ายคลึงกับเครื่องยนต์อาลักษณ์ของ Facebook (ถ้าคุณคุ้นเคยกับมัน) และสามารถนำมาใช้ในการจัดการกระแสกิจกรรม.
มันทำงานโดยการช่วยให้นักพัฒนาที่จะรักษาหนึ่งหรือมากกว่าลำธารกิจกรรม (หรือฟีด).
ฟีดเหล่านี้สามารถจัดในหัวข้อและออกอากาศแล้ว (ตีพิมพ์) ให้กับผู้บริโภคที่จองซื้อทั้งหมด.
ส่วนของคาฟคาที่จัดการและเผยแพร่ฟีดที่เรียกว่าผู้ผลิต.
คาฟคาเป็นพื้นชั้นกลางระหว่างผู้ผลิตและผู้บริโภคที่เป็นระบบที่ซับซ้อนที่สามารถจัดการกับชนิดของการจราจรใด ๆ และขออยู่กับชนิดของระดับใด.
นี้เป็นเพราะคาฟคาถูกสร้างขึ้นเพื่อจัดการกับสถาปัตยกรรมเซิร์ฟเวอร์กระจายช่วยให้นักพัฒนาที่จะไต่ระบบผับ / ย่อยของพวกเขาในการให้บริการคลาวด์.
มีอะไรใหม่ ข่าวประชาสัมพันธ์ฉบับนี้.
- Java ผลิตใหม่เพื่อความสะดวกในการดำเนินงานและเพิ่มประสิทธิภาพการทำงาน
- ลบหัวข้อการสนับสนุน.
- การตั้งค่าต่อหัวข้อของการตั้งค่าเพื่อความมั่นคงมากกว่าความพร้อม.
- Scala 2.11 การสนับสนุนและการสนับสนุนที่ลดลงสำหรับ Scala 2.8.
- การบีบอัด LZ4.
มีอะไรใหม่ ในรุ่น 0.8.2.1:
- A ผลิต Java ใหม่เพื่อความสะดวกในการดำเนินงานและเพิ่มขึ้น ผลการดำเนินงาน.
- ลบหัวข้อการสนับสนุน.
- การตั้งค่าต่อหัวข้อของการตั้งค่าเพื่อความมั่นคงมากกว่าความพร้อม.
- Scala 2.11 การสนับสนุนและการสนับสนุนที่ลดลงสำหรับ Scala 2.8.
- การบีบอัด LZ4.
มีอะไรใหม่ ในรุ่น 0.8.0-beta1:.
- เครื่องมือที่มีอยู่คง perf
- สายการผลิตที่มีอยู่และผู้บริโภคที่จะใช้โครงสร้างข้อมูล ZK ใหม่.
- สร้าง / ลบเส้นทาง ZK สำหรับหัวข้อในเครื่องมือผู้ดูแลระบบ.
- ดำเนินการควบคุมที่ฝังตัว.
มีอะไรใหม่ ในรุ่น 0.7.1:
- หลีกเลี่ยงข้อความซ้ำในช่วง rebalance ผู้บริโภค
- การสนับสนุนที่กำหนดส่ง / รับซ็อกเก็ตขนาดบัฟเฟอร์ในเซิร์ฟเวอร์
- javaapi ZookeeperConsumerConnectorTest ซ้ำกันจำนวนมากในการทดสอบรุ่นสกาล่า
- ตรวจ # retries rebalance ของผู้บริโภคที่กำหนด
- SyncProducer ควรเข้าสู่ระบบโฮสต์และพอร์ตถ้าไม่สามารถเชื่อมต่อ.
- ลดข้อความที่ซ้ำกันเสิร์ฟโดยผู้บริโภค Kafka สำหรับหัวข้อที่ไม่มีการบีบอัด
- หลีกเลี่ยงการเข้าสู่ระบบโดยตรง StackTrace
- ทำให้เวลาในช่วง backoff rebalance ผู้บริโภคที่กำหนด
- ปรับปรุง log4j appender ใช้ kafka.producer.Producer และการสนับสนุน zk.connect | เลือก broker.list
- เฉพาะกิจการออกคาฟคามิร์เรอร์ลง app แบบสแตนด์อะโลน
- ผลิต Hadoop ควรใช้ balancer โหลดซอฟแวร์
มีอะไรใหม่ ในรุ่น 0.7.0:
- คาฟคาในขณะนี้สนับสนุนการบีบอัดระดับบล็อก ดูวิกิพีเดียการบีบอัดเพื่อดูรายละเอียด ปัจจุบัน gzip เพียง แต่เป็น sup รังเพลิง.
- เข้าสู่ระบบการเก็บรักษาในขณะนี้จะขึ้นอยู่กับพื้นที่ (log.retention.size).
มีอะไรใหม่ ในรุ่น 0.6:
- ถาวร:
- SimpleProducer สูญเสียข้อความเมื่อซ็อกเก็ตที่ได้รับการยกเว้น io
- หากผู้ผลิตไม่ถูกต้องส่ง MessageSet โบรกเกอร์จะผนวกมันเสียหายล็อก
- ByteBufferMessageSet บันทึกข้อผิดพลาดเกี่ยวกับการเรียกขนาด
- ปิด Kafka เมื่อมีข้อผิดพลาดดิสก์ IO ใด ๆ
- เผยแพร่เซิร์ฟเวอร์ข้อยกเว้นทั้งหมดให้กับผู้บริโภค
- ปิด () ใน SimpleConsumer ควรจะทำข้อมูลให้ตรงกัน
- เอกสารรหัสผู้บริโภค
- ปรับปรุง EventHandler ใน AsyncProducer
- ผลิตตามดูแลสัตว์ไม่เอานายหน้าตายจากรายการในขณะที่การให้บริการการร้องขอผลิต
- ผู้บริโภคข้อผิดพลาดในระหว่างการบันทึกใกล้
- ปรับปรุง:
- ทำความสะอาดทดสอบ jUnit
- MessageSet ไม่ใช้ Java iterable
- Encoder เริ่มต้นสำหรับคาฟคา log4 appender
- อย่างชัดเจนชื่อกระทู้ทั้งหมดที่
- Refactor API สาธารณะเข้าไปใน Java และสกาล่า API
- การปรับปรุงเอกสาร API สำหรับการ APIs ส่วนกลางทั้งหมด
- ถอดจาวา FileMessageSet API
- ทดสอบหน่วยล้มเหลวในบางเครื่องลินุกซ์
- สร้างโครงการย่อย SBT สำหรับ perf ตัวอย่าง contrib ที่กำลังใช้มด
- เพิ่ม JMX สำหรับการเปลี่ยนระดับ log4j แบบไดนามิกที่เซิร์ฟเวอร์ Kafka
- อัพเกรด Zookeeper 3.3.3
- javaapi MessageSet ไม่จำเป็นต้องใช้ซ็อกเก็ต writeTo
- คุณสมบัติใหม่:
- ผลิตใหม่ API
ความคิดเห็นที่ไม่พบ