Apache Kafka

Apache Kafka (siz tanış edirsinizsə) və fəaliyyəti axınları idarə etmək üçün istifadə edilə bilər Facebook Scribe mühərrik kimi.

Bu developers bir və ya daha çox fəaliyyət axını (və ya feeds) saxlamaq üçün imkan çalışır.

Bu feeds mövzular təşkil edilə bilər, və sonra (nəşr) yayımlanacaq.

feeds idarə və dərc Kafka hissələri istehsalçıları deyilir.

Kafka əsasən istehsalçılar və istehlakçılar arasında orta təbəqə, miqyaslı istənilən yol və sorğuların hər cür idarə edə bilərsiniz kompleks sistemdir.

Kafka developers bulud xidmətləri öz Pub / sub sistemləri miqyaslı imkan verir, paylanmış server arxitekturaları idarə etmək üçün inşa edilmişdir, çünki bu.

Yeni nə Bu azad.

• həyata keçirilməsi rahatlığı və inkişaf etmiş performans üçün yeni Java istehsalçı
• mövzu dəstəyi sil.

Mövcudluğu üzərində ardıcıllıq üçün üstünlük mövzusu konfiqurasiya Per
• .

Scala 2.8 üçün
• Scala 2.11 dəstək və düşmə dəstək.
• LZ4 sıxılma.

Yeni həyata keçirilməsi rahatlığı üçün versiya 0.8.2.1:

• A yeni Java istehsalçısı və inkişaf etmiş nə performance.
• mövzu dəstəyi sil.

Mövcudluğu üzərində ardıcıllıq üçün üstünlük mövzusu konfiqurasiya Per
• .

Scala 2.8 üçün
• Scala 2.11 dəstək və düşmə dəstək.
• LZ4 sıxılma.

version 0.8.0-Beta1 yeni nədir.

• Sabit mövcud Performans alətləri
• Wire mövcud İstehsalçı və istehlakçı yeni ZK data strukturu istifadə etmək.
• / yarat admin alət bir mövzu üçün ZK yol silin.
• Icra əlaqədar nəzarətçi.

versiyası 0.7.1 yeni nədir:

• istehlakçı yenidən tarazlaşdırılması zamanı təqlid mesaj almaq
• Support yapılandırılabilir göndərmək / server yuva bufer ölçüsü almaq
• javaapi ZookeeperConsumerConnectorTest scala versiyası bir çox testlər dublikatları
• istehlakçı yenidən tarazlaşdırılması # yapılandırılabilir retries olun

Qoşula bilmirsə
• SyncProducer ana və port daxil edin.
• sıkıştırılmamış mövzular üçün Kafka istehlakçı xidmət dublikat mesaj azaltmaq
• birbaşa giriş StackTrace çəkinin
• istehlakçı yenidən tarazlaşdırılması zamanı Backoff vaxt olun yapılandırılabilir
• kafka.producer.Producer istifadə Log4J APPENDER və dəstək zk.connect təkmilləşdirilməsi | broker.list variantları
• bağımsız bir app daxil aynalama Kafka həyata ayırın
• Hadoop istehsalçı istifadə etməlidir proqram təminatı yük tarazlayıcı

versiyası 0.7.0 yeni nədir:

• Kafka artıq blok səviyyədə sıxılma dəstəkləyir. Ətraflı məlumat üçün sıxılma wiki baxın. Hal-hazırda yalnız gzip daşıdıq SUP.
• indi kosmik (log.retention.size) asılı ola bilər tutma daxil olun.

versiyası 0.6 yeni nədir:

• Sabit Bugs:

Socket bir io istisna olur zaman
• SimpleProducer mesajları itirmək
• istehsalçı yalnış MessageSet broker günlük fitnə, onu əlavə edəcək göndərir
• ByteBufferMessageSet ölçüsü almaq haqqında səhv logs
• Kapatma Kafka hər hansı bir disk IO səhv olduqda
• server istehlakçıya bütün istisnalar təbliğ
• SimpleConsumer yaxın () senkronize olunmalıdır
• Consumer Kodu sənədlərin
• AsyncProducer da EventHandler təkmilləşdirilməsi

Bir istehsal sorğu vəzifə edərkən
• zookeeper əsasında İstehsalçı siyahısından bir ölü broker aradan qaldırılması deyil

Yaxın ərzində
• Consumer logs ERROR
• təkmilləşdirilməsi:
• Clean-up JUnit test
• MessageSet Java tətbiq etmir iterable
• Kafka üçün Default Encoder Log4 APPENDER
• Aydın bütün mövzuları ad
• java və Scala API daxil Refactor ictimai API
• bütün ictimai API API docs təkmilləşdirilməsi
• java FileMessageSet API Sil
• Unit test bəzi Linux maşın uğursuz
• Hal-hazırda istifadə PERF, nümunələri, contrib üçün SBT sub layihələr yaradın Ant
• Kafka server dinamik Log4J səviyyəsi dəyişdirmək üçün JMX əlavə et
• 3.3.3 Zookeeper yükseltin
• javaapi MessageSet writeTo yuva həyata keçirmək lazım deyil
• New Features:
• Yeni istehsalçı API