Apache Kafka

Apache Kafka (buna tanıdık iseniz) ve etkinlik akışı işlemek için kullanılabilir Facebook'un Scribe motoruna benzer.

geliştiricilerin bir veya daha fazla etkinlik akışlarını (veya beslemeleri) korumak için izin vererek çalışır.

Bu beslemeleri konularda organize edilebilir ve daha sonra (yayınlanmış) yayın.

beslemeleri yönetmek ve yayınlamak Kafka parçaları üreticilerini denir.

Kafka temelde üretici ve tüketiciler arasındaki orta tabaka, ölçek her türlü trafik ve isteklerini her türlü işleyebilir karmaşık bir sistemdir.

Kafka geliştiriciler bulut hizmetleri kendi Pub / alt sistemlerini büyütmek için izin dağıtılmış sunucu mimarilerini işlemek için inşa edilmiş olmasıdır.

Yeni Ne Bu sürüm:.

• uygulama kolaylığı ve gelişmiş performans için yeni bir Java üretici
• konu desteğini silin.

kullanılabilirliği üzerinde tutarlılık için tercih konusu yapılandırması Başına
• .

Scala 2.8
• Scala 2.11 desteği ve bırakarak desteği.
• LZ4 sıkıştırma.

yeni uygulama kolaylığı için sürümü 0.8.2.1:

• A yeni bir Java üreticisi ve geliştirilmiş nedir performans.
• konu desteğini silin.

kullanılabilirliği üzerinde tutarlılık için tercih konusu yapılandırması Başına
• .

Scala 2.8
• Scala 2.11 desteği ve bırakarak desteği.
• LZ4 sıkıştırma.

sürüm 0.8.0-beta1 yeni nedir.

• Sabit mevcut perf araçları
• Tel mevcut üretici ve tüketici yeni ZK veri yapısını kullanmak.
• / Yarat yönetici aracında bir konu için ZK yolunu silin.
• Uygulanan gömülü denetleyici.

sürümünde 0.7.1 yeni Nedir:

• tüketici yeniden dengelemek sırasında çoğaltılamaz mesajı kaçının
• Destek yapılandırılabilir gönderme / sunucu soket tampon boyutu almak
• JAVAAPI ZookeeperConsumerConnectorTest scala sürümünde birçok test çiftleri
• tüketici yeniden dengelemek içinde yapılandırılabilir dener olun

bağlanamıyor eğer
• SyncProducer host ve port oturum açması gerekir.
• sıkıştırılmamış konular için kafka tüketici tarafından sunulan yinelenen iletileri azaltın
• doğrudan günlüğü stacktrace kaçının
• tüketici yeniden dengelemek sırasında backoff zaman olun yapılandırılabilir
• kafka.producer.Producer kullanmak için log4j appender ve destek zk.connect geliştirin | broker.list seçenekleri
• Tek başına bir uygulama içine yansıtma Kafka ayırınız
• Hadoop üreticisi kullanmanız gereken yazılım yük dengeleyici

sürümünde 0.7.0 yeni Nedir:

• Kafka artık blok düzeyinde sıkıştırmayı destekler. Ayrıntılar için sıkıştırma wiki'yi bakınız. Şu anda sadece gzip taşıdık sup olduğunu.
• Şimdi uzayda (log.retention.size) bağlı olabilir tutma yapın.

sürümünde 0.6 yeni Nedir:

• Sabit Hatalar:

soket bir io istisna aldığında
• SimpleProducer mesajları kaybetmek
• yapımcı geçersiz MessageSet broker günlüğü bozulmasını, onu ekleyeceği gönderirse
• ByteBufferMessageSet boyutu getirme konusunda hata günlükleri
• Kapatma Kafka herhangi bir disk IO hata olduğunda
• Sunucu tüketiciye tüm istisnalar yay
• SimpleConsumer close () senkronize olmalıdır
• Tüketici Kod belgeleri
• AsyncProducer içinde EventHandler geliştirin

Bir üretmek isteği hizmet ederken
• zookeeper Temel Yıllı Üretici kendi listeden ölü komisyoncu kaldırmaz

yakın sırasında
• Tüketici günlükleri HATA
• İyileştirmeler:
• Temizlik-up jUnit testi
• MessageSet Java uygulamıyor iterable
• Kafka için Varsayılan Encoder log4 appender
• Açıkça bütün konuları isim
• java ve Scala API içine Refactor kamu API
• tüm kamu API'ler için API docs geliştirin
• java FileMessageSet API Kaldır
• Birim test bazı Linux makinelerde başarısız
• anda kullanmakta olduğunuz perf, örnekler, contrib için SBT alt projeler oluşturma Ant
• Kafka sunucusunda dinamik log4j düzeyini değiştirmek için JMX ekle
• 3.3.3 zookeeper yükseltme
• JAVAAPI MessageSet WriteTo soket uygulamak gerekmez
• Yeni Özellikler:
• Yeni yapımcı API