Apache Kafka

Apache Κάφκα είναι παρόμοια με το Scribe κινητήρα του Facebook (αν είστε εξοικειωμένοι με αυτό) και μπορεί να χρησιμοποιηθεί για να χειριστεί ρεύματα δραστηριότητα.

Λειτουργεί με την επιτρέποντας στους προγραμματιστές να διατηρήσουν ένα ή περισσότερα ρεύματα δραστηριότητας (ή τροφές).

Αυτές οι τροφές μπορεί να οργανωθεί σε θέματα, και στη συνέχεια μεταδίδεται (δημοσιευθεί) σε όλους τους καταναλωτές εγγραφεί.

Τα μέρη του Κάφκα που διαχειρίζονται και να δημοσιεύουν τις τροφές που ονομάζεται παραγωγούς.

Κάφκα είναι βασικά το μεσαίο στρώμα μεταξύ των παραγωγών και των καταναλωτών, ένα πολύπλοκο σύστημα που μπορεί να χειριστεί οποιοδήποτε είδος της κίνησης και των αιτήσεων για κάθε τύπο κλίμακας.

Αυτό συμβαίνει επειδή ο Κάφκα χτίστηκε για να χειριστεί κατανεμημένες αρχιτεκτονικές server, επιτρέποντας στους προγραμματιστές να αναβαθμίσουν Pub / υποσυστήματα τους σχετικά με τις υπηρεσίες cloud.

Τι είναι καινούργιο αυτή η έκδοση:.

• Ένας νέος παραγωγός Java για την ευκολία της εφαρμογής και βελτιωμένη απόδοση
• Διαγραφή στήριξης θέμα.
• Ανά θέμα τη διαμόρφωση της προτίμησης για λόγους συνέπειας πάνω από τη διαθεσιμότητα.
• Σκάλα 2.11 υποστήριξη και τη ρίψη υποστήριξη για Scala 2.8.
• συμπίεση LZ4.

Τι είναι καινούργιο στην έκδοση 0.8.2.1:

• A νέος παραγωγός Java για την ευκολία της εφαρμογής και της ενισχυμένης απόδοση.
• Διαγραφή στήριξης θέμα.
• Ανά θέμα τη διαμόρφωση της προτίμησης για λόγους συνέπειας πάνω από τη διαθεσιμότητα.
• Σκάλα 2.11 υποστήριξη και τη ρίψη υποστήριξη για Scala 2.8.
• συμπίεση LZ4.

Τι είναι καινούργιο στην έκδοση 0.8.0-beta1:.

• Σταθερή υπάρχοντα εργαλεία PERF
• Wire υφιστάμενων παραγωγού και του καταναλωτή να χρησιμοποιήσει τη νέα δομή δεδομένων ΖΚ.
• Δημιουργία / διαγραφή διαδρομή ZK για ένα θέμα σε ένα εργαλείο διαχείρισης.
• εφαρμόσει ένα ενσωματωμένο ελεγκτή.

Τι είναι καινούργιο στην έκδοση 0.7.1:

• αποφευχθούν διπλές μήνυμα κατά την εξισορρόπηση των καταναλωτών
• Υποστήριξη ρύθμισης αποστολής / λήψης μέγεθος του buffer υποδοχή στο διακομιστή
• JAVAAPI ZookeeperConsumerConnectorTest αναπαράγει πολλές δοκιμές στην έκδοση Scala
• Κάντε # εξισορρόπηση των καταναλωτών επαναλήψεις ρύθμισης
• SyncProducer πρέπει να συνδεθείτε υποδοχής και το λιμάνι, αν δεν μπορείτε να συνδεθείτε.
• Μείωση διπλά μηνύματα που εξυπηρετούνται από τον καταναλωτή Κάφκα για θέματα ασυμπίεστο
• Αποφύγετε την καταγραφή stacktrace απευθείας
• Κάντε χρόνο κατά τη διάρκεια της υποχώρησης εξισορρόπηση των καταναλωτών ρύθμισης
• Βελτίωση log4j appender να χρησιμοποιήσετε kafka.producer.Producer, και την υποστήριξη zk.connect | επιλογές broker.list
• Χωρίστε έξω Κάφκα αντανακλώντας σε ένα αυτόνομο app
• Hadoop παραγωγός πρέπει να χρησιμοποιήσετε το λογισμικό εξισορρόπησης φόρτου

Τι είναι καινούργιο στην έκδοση 0.7.0:

• Κάφκα τώρα υποστηρίζει συμπίεση επίπεδο μπλοκ. Δείτε wiki συμπίεσης για λεπτομέρειες. Επί του παρόντος, μόνο το gzip sup φορητότητα.
• Συνδεθείτε κατακράτηση μπορούν τώρα να εξαρτώνται από το διάστημα (log.retention.size).

Τι είναι καινούργιο στην έκδοση 0.6:

• Σταθερή σφάλματα:
• SimpleProducer χάσουν τα μηνύματα όταν παίρνει μια υποδοχή IO εξαίρεση
• Εάν ο παραγωγός στέλνει ένα άκυρο MessageSet ο μεσίτης θα επισυνάπτει, διαφθείρει το αρχείο καταγραφής
• ByteBufferMessageSet αρχεία καταγραφής σφαλμάτων για να φέρω το μέγεθος
• Shutdown Κάφκα, όταν υπάρχει οποιοδήποτε δίσκο IO error
• πολλαπλασιάζονται διακομιστή, όλες οι εξαιρέσεις των καταναλωτών
• κοντά () σε SimpleConsumer πρέπει να συγχρονιστούν
• τεκμηρίωση Κώδικα Καταναλωτών
• Βελτίωση EventHandler σε AsyncProducer
• Ο Παραγωγός zookeeper βάση δεν αφαιρεί ένα νεκρό μεσίτη από τον κατάλογο που εκτίει αίτημα προϊόντα
• κούτσουρα Καταναλωτών σφάλμα κατά την στενή
• Βελτιώσεις:
• δοκιμών Clean-up JUnit
• MessageSet δεν εφαρμόζει Java iterable
• Default κωδικοποιητή για Κάφκα log4 appender
• Ρητή αναφέρουμε όλα τα θέματα
• Refactor δημόσια API σε Java και τη Σκάλα του API
• Βελτίωση API Έγγραφα για όλες τις δημόσιες APIs
• Αφαιρέστε το Java API FileMessageSet
• δοκιμή μονάδα αποτύχει σε κάποια μηχανήματα Linux
• Δημιουργία SBT υποέργων για την PERF, παραδείγματα, contrib που χρησιμοποιούν επί του παρόντος Αντ
• Προσθήκη JMX για την αλλαγή επιπέδου log4j δυναμικά στο διακομιστή Κάφκα
• Αναβάθμιση σε 3.3.3 zookeeper
• JAVAAPI MessageSet δεν χρειάζεται να εφαρμόσουν υποδοχή writeTo
• Νέα Χαρακτηριστικά:
• Νέα παραγωγό API