Apache Kafka

Apache Kafkos " yra panašus į" Facebook "Scribe variklio (jei esate susipažinę su ja), ir gali būti naudojama rankena veiklos srautus.

Jis veikia leidžia kūrėjams išlaikyti vieną ar daugiau veiklos srautus (arba pašarai).

Šios kanalai gali būti organizuojamas pranešimus, tada transliuoti (paskelbta), kad pasirašytų vartotojams.

apie Kafka dalys, tvarkyti ir skelbti kanalus vadinami gamintojais.

Kafka iš esmės yra vidurinis sluoksnis tarp gamintojų ir vartotojų, sudėtinga sistema, kuri gali dirbti bet eismo ir prašymų natūra bet masto tipą.

Tai todėl, kad Kafka buvo pastatytas tvarkyti platinami serverio architektūra, leidžianti kūrėjai masto savo Baras / sub sistemas debesys paslaugų.

Kas naujo Ši laida.

• Naujas "Java" gamintojas dėl patogumo įgyvendinimą ir padidinti jų efektyvumą;
• Ištrinti temą paramą.
• per temą konfigūracijos pirmenybės nuoseklumo per laisvas.
• Scala 2.11 parama ir nuleisti parama Scala 2.8.
• LZ4 suspaudimo.

Kas naujo versijoje 0.8.2.1:

• A~~HEAD=pobj naujos "Java gamintojui lengviau įgyvendinti ir stiprinti efektyvumą.
• Ištrinti temą paramą.
• per temą konfigūracijos pirmenybės nuoseklumo per laisvas.
• Scala 2.11 parama ir nuleisti parama Scala 2.8.
• LZ4 suspaudimo.

Kas naujo version 0.8.0-beta1:.

• Fiksuoti esami PERF Įrankiai
• Viela esamas gamintojų ir vartotojų naudoti naują ZK duomenų struktūrą.
• Sukurti / ištrinti ZK kelią temą A admin priemonę.
• įgyvendino integruotas valdiklis.

Kas naujo versijos 0.7.1:

• Venkite dubliuoti pranešimą per vartotojų naujo subalansuojama
• Pagalba konfigūruojama siųsti / gauti lizdas buferio dydis serveryje
• javaapi ZookeeperConsumerConnectorTest dublikatų daug bandymus Scala versija
• Padaryti # vartotojų naujo subalansuojama bando prisijungti konfigūruojama
• SyncProducer turėtų prisijungti priimančiosios ir prievadą, jei negali prisijungti.
• Sumažinti pasikartojančius pranešimus aptarnauja Kafka vartotojui už nesuspaustų pranešimus
• Venkite registravimo stacktrace "derinimo įrankį tiesiogiai;
• Padaryti backoff kartą per vartotojų naujo subalansuojama konfigūruojama
• Pagerinti log4j appender naudoti kafka.producer.Producer ir parama zk.connect | broker.list galimybes
• atskirti Kafka veidrodžius į atskirą app
• Hadoop gamintojas turėtų naudoti programinės įrangos apkrovos balansavimo,

Kas naujo 0.7.0 versija:

• Kafka dabar palaiko bloko lygiu suspaudimo. Žiūrėti suspaudimo wiki detales. Šiuo metu tik gzip yra sup perkeltas.
• Prisijungti susilaikymas dabar gali priklausyti nuo vietos (log.retention.size).

Kas naujo versijos 0.6:

• Suremontuota:
• SimpleProducer prarasti pranešimus, kai lizdas gauna io išimtis;
• Jei gamintojas siunčia invalidu MessageSet brokeris pridėkite jį tvirkinimu žurnalą
• ByteBufferMessageSet rąstų klaidą apie atnešti dydį;
• shutdown Kafka, jei yra disko IO klaida
• Paplitimas serveris visas išimtis vartotojui
• arti () in SimpleConsumer turėtų būti sinchronizuojami
• Vartotojų kodekso dokumentus
• Pagerinti EventHandler į AsyncProducer
• Zookeeper remiantis Gamintojas nepašalina negyvą brokeris iš savo sąrašo, o tarnauja gaminti prašymą
• Vartotojų rąstų KLAIDA per arti,
• Patobulinimai:
• Išvalyti junit testas
• MessageSet neįgyvendina Java iterable
• Numatytasis daviklis Kafka log4 appender
• Aiškiai įvardyti visas temas
• refactor viešojo API į "Java" ir "Scala API
• Pagerinti API docs visų viešųjų API
• Pašalinti java FileMessageSet API
• vieneto testas nepavyksta dėl kai Linux mašinos
• Sukurti SBT sub projektus atl, pavyzdžių, įnašo, kad šiuo metu naudojatės Ant
• Pridėti JMX keisti log4j lygį dinamiškai Kafka serverio
• Atnaujinti Zookeeper 3.3.3
• javaapi MessageSet nereikia įgyvendinti writeTo lizdą
• Naujos funkcijos: "
• Nauja gamintojas API