apache-kafka
Consumatore di Kafka - comportamento del sondaggio
Kafka produttore TimeoutException: scadenza 1 record (s)
Kafka: API consumer vs API stream
Come scrivere un file in Kafka Producer
Come ottenere l'ultimo offset per una partizione per un argomento kafka?
Il supporto di Kafka richiede i messaggi di risposta
Come creare argomenti in Apache kafka?
Comprensione Kafka Argomenti e partizioni
Spring Boot Kafka: impossibile avviare l'utente a causa di NoSuchBeanDefinitionException
Errore nella pubblicazione del messaggio sull'argomento di Kafka
Limita le dimensioni dei lotti di Kafka quando usi Spark Streaming
Gestire i messaggi non validi utilizzando l'API Streams di Kafka
Kafka - Questo server non è il leader per quella partizione argomento
Kafka Connect Modalità distribuita Il coordinatore del gruppo non è disponibile
Come leggere i dati usando Kafka Consumer API dall'inizio?
Elimina il messaggio dopo averlo consumato in KAFKA
La chiave è richiesta come parte dell'invio di messaggi a Kafka?
Kafka recupero dei metadati del consumatore per gli argomenti non riuscito
Che cosa significa "Riequilibrio" in Apache Kafka?
Spark Streaming: leggi e scrivi su Kafka argomento
Kafka - Implementazione di coda in ritardo utilizzando il consumer di alto livello
Ricevi l'ultimo messaggio dallo script della console utente di kafka
Kafka come leggere dall'argomento __consumer_offsets
Il consumatore non riceve messaggi, kafka console, nuovo consumer api, Kafka 0.9
Possono più utenti Kafka leggere lo stesso messaggio dalla partizione
Kafka Consumer Marking the coordinator 2147483647 dead
Come configurare la registrazione per i produttori di Kafka?
Come verificare se Kafka Server è in esecuzione?
Come posso ottenere l'ULTIMO offset di un argomento di kafka?
come impostare il nome del gruppo quando si consumano messaggi in kafka usando la riga di comando
Differenza tra session.timeout.ms e max.poll.interval.ms per Kafka 0.10.0.0 e versioni successive
comprendendo l'id del gruppo di consumatori
Kafka Il consumatore ottiene la coppia valore-chiave
Kafka bootstrap-servers vs zookeeper in kafka-console-consumer
Conteggio Numero di messaggi memorizzati in un argomento di kafka
Kafka ID gruppo predefinito del consumatore
Kafka10.1 heartbeat.interval.ms, session.timeout.ms e max.poll.interval.ms
Non chiaro sul significato di auto.offset.reset e enable.auto.commit in Kafka
In che modo Kafka memorizza le compensazioni per ogni argomento?
Come riconoscere lo scostamento corrente in primavera kafka per il commit manuale
Spring Kafka Producer non invia a Kafka 1.0.0 (Magic v1 non supporta le intestazioni dei record)
Qual è la differenza tra kafka i valori di offset più recenti e più recenti
Semplice incorporato Kafka con avvio a molla
Kafka ERRORE consumatore console "Offset commit non riuscito sulla partizione"
Perché Kafka hanno prodotto INVALID_FETCH_SESSION_Epoch dopo l'aggiornamento a 1.1?
Broker leader senza un errore di listener corrispondente in kafka
Apache Camel contro Apache Kafka
Come ottenere dati dal vecchio punto di offset in Kafka?
Ribilanciamento del problema durante la lettura dei messaggi in Kafka
C'è un modo semplice per installare Kafka su Windows?
Esecuzione in LeaderNotAvailableException quando si utilizza Kafka 0.8.1 con Zookeeper 3.4.6
Zookeeper è un must per Kafka?
Come creare un argomento in Kafka attraverso Java
Perché i consumatori di Kafka si connettono a Zookeeper ei produttori ottengono metadati dai broker?
Come verificare se ZooKeeper è in esecuzione o attivo dal prompt dei comandi?
Kafka: Ottieni l'host broker da ZooKeeper
Kafka sul multi-nodo di Kubernetes
Errore durante l'esecuzione di Kafka su Windows
Spark Streaming + Kafka: SparkException: Impossibile trovare gli offset principali per Set
Lettura descrittore artefatto non riuscita: IntelliJ
errore durante l'avvio del broker kafka
Come faccio a eliminare un gruppo di consumatori Kafka per reimpostare gli offset?
Kafka autenticazione del guardiano dello zoo SASL
Ottenuto KeeperException a livello di utente durante l'elaborazione
Elenca tutti gli argomenti di kafka
Quali sono i vantaggi e gli svantaggi di Kafka rispetto ad Apache Pulsar
Kafka 1.0 si ferma con errore FATAL SHUTDOWN. La directory dei registri non è riuscita
Backup/ripristino di kafka e zookeeper
Integrazione di Spark Structured Streaming con il registro degli schemi Confluent
Come riavviare correttamente il server kafka?
zookeeper non è un'opzione riconosciuta quando si esegue kafka-console-consumer.sh
Errore dell'encoder durante il tentativo di mappare la riga del frame di dati sulla riga aggiornata
Come preparare i dati in un formato LibSVM da DataFrame?
Encoder per il tipo di riga Spark set di dati
Come possiamo creare un argomento in Kafka dal IDE usando l'API
Modellazione dei dati con Kafka? Argomenti e partizioni
Usando Kafka come un (CQRS) Eventstore. Buona idea?
Come posso inviare messaggi di grandi dimensioni con Kafka (oltre 15 MB)?
Errore di esempio di Apache Kafka: impossibile inviare il messaggio dopo 3 tentativi
Quando / come viene finalmente rimosso un argomento "contrassegnato per l'eliminazione"?
Elimina argomento in Kafka 0.8.1.1
Come ottenere l'elenco degli argomenti dal server kafka in Java
kafka-server-stop.sh non funziona quando Kafka è partito dallo script Python
In Apache Kafka perché non ci possono essere più istanze di consumo rispetto alle partizioni?
Perché non riesco a collegarmi a Kafka da fuori?
Come trovare la versione di kafka in linux