Apache Kafka

Apache Кафка е подобна на Scribe двигателя Facebook (ако сте запознати с него) и може да се използва за обработка на потоци от дейността.

Той действа, като позволява на разработчиците да поддържат един или повече потоци от дейността (или се храни).

Тези емисии могат да бъдат организирани в теми, и след това излъчват (публикуван) по всички абонирани потребители.

Частите на Кафка, които управляват и публикуват фуражите, се наричат ​​производителите.

Кафка е в основата на средния слой между производителите и потребителите, сложна система, която може да се справи с всеки вид трафик и исканията на всякакъв тип мащаб.

Това е така, защото Кафка е бил построен, за да се справят разпределени архитектури сървър, което позволява на разработчиците да мащабират своите Pub / подсистеми на облачни услуги.

Какво ново в тази версия:.

• A нов производител Java за по-лесно прилагане и по-добри резултати
• Изтриване на тема поддръжка.
• Per тема конфигурация на предпочитание за постоянство във наличност.
• Scala 2.11 подкрепа и подкрепа за отпадане Scala 2.8.
• LZ4 компресия.

Какво ново във версия 0.8.2.1:

• A нов производител Java за по-лесно прилагане и засиленото производителност.
• Изтриване на тема поддръжка.
• Per тема конфигурация на предпочитание за постоянство във наличност.
• Scala 2.11 подкрепа и подкрепа за отпадане Scala 2.8.
• LZ4 компресия.

Какво ново във версия 0.8.0-бета1:.

• Фиксирани съществуващите инструменти Perf
• Тел съществуващата производителя и потребителя да използва новата структура ZK данни.
• Създаване / изтриване ZK път за една тема, в инструмент администратор.
• Изпълнено вграден контролер.

Какво ново във версия 0.7.1:

• Избягвайте дублира съобщение по време на потребителите ребалансиране
• Поддръжка конфигурируеми изпращане / получаване размер гнездо буфер в сървъра
• javaapi ZookeeperConsumerConnectorTest дублира много тестове в Скала версия
• Направи # на потребителите ребалансиране опитва отново конфигурируеми
• SyncProducer трябва да влезете хост и порт, ако не може да се свърже.
• Намаляване на дублиращи се съобщения, обслужвани от Кафка потребителя за некомпресирани теми
• Избягвайте сеч stacktrace директно
• Направи време за намаляването на потребителите по време на ребалансиране конфигурируеми
• Подобряване Log4j appender да използвате kafka.producer.Producer, както и подкрепа zk.connect | опции broker.list
• Разделят се Кафка отразявайки в самостоятелно приложение
• производителя Hadoop трябва да използвате софтуер натоварване балансьор

Какво ново във версия 0.7.0:

• Кафка вече поддържа компресия групово ниво. Вижте компресия уики за подробности. В момента само софтуерна е подкрепено.
• Дневник задържане вече могат да зависят от космоса (log.retention.size).

Какво ново във версия 0.6:

• Фиксирани бъгове:
• SimpleProducer губят съобщения, когато гнездото получава Йо изключение
• Ако производителят изпраща невалиден MessageSet брокерът ще го прикрепите, поквара дневника
• ByteBufferMessageSet логва грешка около донесе размер
• Shutdown Кафка, когато има някакъв диск IO грешка
• Пропаганда сървъра всички изключения от потребителите
• тясно () в SimpleConsumer трябва да бъдат синхронизирани
• Consumer Code документация
• Подобряване EventHandler в AsyncProducer
• гледач на животни на базата Продуцентът не отстранява мъртва брокер от списъка по време на излежаване на заявка за продукти
• Потребителски трупи грешка по време на близо
• Подобрения:
• тест Почистване Junit
• MessageSet не изпълнява Java iterable
• Default Encoder за Кафка log4 appender
• Изрично назове всички теми
• Refactor публично API в Java и Scala API
• Подобряване на API документи за всички публични APIs
• Премахване на Java API FileMessageSet на
• Unit тест се провали на някои Linux машини
• Създаване SBT подпроекта за PERF, примери, вноската, която използвате в момента Ant
• Добави JMX за промяна ниво Log4j динамично при Кафка сървъра
• Ъпгрейд Zookeeper 3.3.3
• javaapi MessageSet не трябва да се прилагат writeTo гнездо
• Нови функции:
• New API производителя