it-swarm-id.com

apache-kafka

Kafka Consumer - Perilaku polling

Kafka produser TimeoutException: Kedaluwarsa 1 rekaman

Kafka: API Konsumen vs API Streaming

Cara menulis file ke Kafka Produser

Apakah Kafka mendukung pesan respon permintaan

Bagaimana cara membuat topik di Apache kafka?

Kafka melempar Java.nio.channels.ClosedChannelException

Memahami Kafka Topik dan Partisi

Spring Boot Kafka: Tidak dapat memulai konsumen karena NoSuchBeanDefinitionException

Kesalahan dalam Menerbitkan pesan ke topik Kafka

Batasi ukuran kumpulan Kafka saat menggunakan Spark Streaming

Menangani pesan buruk menggunakan Kafka's Streams API

Kafka - Server ini bukan pemimpin untuk partisi topik itu

Kafka Connect mode Terdistribusi Koordinator grup tidak tersedia

Kesalahan membuat topik Kafka: - faktor replikasi lebih besar dari broker yang tersedia

Bagaimana cara membaca data menggunakan Kafka Consumer API dari awal?

Apakah kunci diperlukan sebagai bagian dari pengiriman pesan ke Kafka?

Kafka konsumen mengambil metadata untuk topik gagal

Apa yang dimaksud dengan "Menyeimbangkan Kembali" di Apache Kafka konteks?

Spark Streaming - baca dan tulis di topik Kafka

Kafka - Penundaan implementasi Antrian menggunakan konsumen tingkat tinggi

Kafka daftar konsumen

Dapatkan pesan terakhir dari skrip konsol konsumen kafka

Kafka cara membaca dari topik __consumer_offsets

Konsumen tidak menerima pesan, konsol kafka, api konsumen baru, Kafka 0.9

Dapatkah beberapa konsumen Kafka membaca pesan yang sama dari partisi

Kafka Consumer Menandai koordinator 2147483647 mati

Bagaimana cara mengkonfigurasi logging untuk produsen Kafka?

Kafka di Docker tidak berfungsi

Bagaimana cara memeriksa apakah Kafka Server sedang berjalan?

Kafka dengan .Net Client

Bagaimana saya bisa mendapatkan offset TERBARU dari topik kafka?

Kafka dan aturan firewall

cara mengatur nama grup saat menggunakan pesan dalam kafka menggunakan baris perintah

Perbedaan antara session.timeout.ms dan max.poll.interval.ms untuk Kafka 0.10.0.0 dan versi yang lebih baru

Kafka Terima kesalahan Tidak ada url bootstrap yang dapat diberikan yang diberikan di server bootstrap

memahami id grup konsumen

Kafka Konsumen mendapatkan pasangan nilai kunci

Kafka bootstrap-server vs zookeeper di kafka-console-consumer

Menghitung Jumlah pesan yang disimpan dalam topik kafka

Kafka Id Grup default konsumen

Tidak jelas tentang arti auto.offset.reset dan enable.auto.commit di Kafka

Bagaimana Kafka menyimpan offset untuk setiap topik?

Bagaimana cara mengakui offset saat ini di musim semi kafka untuk komit manual

Spring Kafka - Bagaimana cara mereset offset ke terbaru dengan id grup?

Spring Kafka Produser tidak mengirim ke Kafka 1.0.0 (Magic v1 tidak mendukung header catatan)

Apa perbedaan antara kafka nilai offset awal dan terbaru

Contoh uji Kafka tertanam sederhana dengan spring boot

Bagaimana cara menulis konsumen Kafka - single threaded vs multi threaded

Kafka konsumen konsol ERROR "Komitmen offset gagal pada partisi"

Pialang pemimpin tanpa kesalahan pendengar yang cocok di kafka

Apache Camel vs Apache Kafka

Classpath kosong. Silakan bangun proyek terlebih dahulu, mis. dengan menjalankan './gradlew jar -PscalaVersion = 2.11.12'

Bagaimana cara mendapatkan data dari titik offset lama di Kafka?

Apakah ada cara untuk menghapus semua data dari suatu topik atau menghapus topik sebelum setiap kali dijalankan?

Apache Kafka vs Apache Storm

Memperbaiki masalah saat membaca pesan di Kafka

Apakah ada cara mudah untuk menginstal Kafka di Windows?

Berlari ke LeaderNotAvailableException saat menggunakan Kafka 0.8.1 dengan Zookeeper 3.4.6

Apakah Zookeeper suatu keharusan bagi Kafka?

Kesalahan Apache Kafka di windows - Tidak dapat menemukan atau memuat kelas utama QuorumPeerMain

Kelas KafkaUtils tidak ditemukan di streaming Spark

Mengapa konsumen Kafka terhubung dengan zookeeper, dan produsen mendapatkan metadata dari broker?

Kafka tidak dapat terhubung ke Zookeeper

Bagaimana cara memeriksa apakah ZooKeeper berjalan atau naik dari command prompt?

Kafka di Kubernetes multi-node

Kesalahan saat menjalankan Kafka di Windows

Spark Streaming + Kafka: SparkException: Tidak dapat menemukan offset pemimpin untuk Set

Bagaimana cara menggunakan konsumen multi-thread di kafka 0.9.0?

kesalahan saat memulai broker kafka

Bagaimana cara saya menghapus Grup Konsumen Kafka untuk mereset offset?

Kafka otentikasi zookeeper SASL

Mendapat KeeperException tingkat pengguna saat memproses

Daftar semua topik kafka

Apa kelebihan dan kekurangan dari Kafka lebih dari Apache Pulsar

Kafka 1.0 berhenti dengan kesalahan FATAL SHUTDOWN. Direktori log gagal

Kafka + Zookeeper: Koneksi ke simpul -1 tidak dapat dibuat. Pialang mungkin tidak tersedia

Cadangkan/pulihkan kafka dan zookeeper

Mengintegrasikan Streaming Terstruktur Spark dengan Registri Skema Confluent

Bagaimana cara me-restart server kafka dengan benar?

zookeeper bukan pilihan yang dikenali saat mengeksekusi kafka-console-consumer.sh

Kesalahan enkoder saat mencoba memetakan baris data ke baris yang diperbarui

Bagaimana cara menyiapkan data ke dalam format LibSVM dari DataFrame?

Encoder untuk Tipe Baris Spark Kumpulan data

Bersihkan Kafka Topik

Bagaimana kami bisa membuat topik di Kafka dari IDE menggunakan API

Pemodelan Data dengan Kafka? Topik dan Partisi

Menggunakan Kafka sebagai Eventstore (CQRS). Ide bagus?

Bagaimana saya bisa mengirim pesan besar dengan Kafka (lebih dari 15MB)?

Contoh kesalahan Apache Kafka: Gagal mengirim pesan setelah 3 kali dicoba

Kapan / bagaimana suatu topik "ditandai untuk dihapus" akhirnya dihapus?

Hapus topik di Kafka 0.8.1.1

Cara mendapatkan daftar topik dari server kafka di Jawa

kafka-server-stop.sh tidak berfungsi saat Kafka mulai dari skrip Python

Di Apache Kafka mengapa tidak ada instance konsumen yang lebih dari partisi?

Mengapa saya tidak bisa terhubung ke Kafka dari luar?

Cara menemukan versi kafka di linux

ActiveMQ vs Apollo vs Kafka

Bagaimana cara mengatur opsi Java untuk Kafka?

Cara menentukan ukuran Kafka Cluster