it-swarm-eu.dev

apache-kafka

Consumatore di Kafka - comportamento del sondaggio

Kafka produttore TimeoutException: scadenza 1 record (s)

Kafka: API consumer vs API stream

Il supporto di Kafka richiede i messaggi di risposta

Come creare argomenti in Apache kafka?

Spring Boot Kafka: impossibile avviare l'utente a causa di NoSuchBeanDefinitionException

Comprensione Kafka Argomenti e partizioni

Come scrivere un file in Kafka Producer

Come ottenere l'ultimo offset per una partizione per un argomento kafka?

Errore nella pubblicazione del messaggio sull'argomento di Kafka

Limita le dimensioni dei lotti di Kafka quando usi Spark Streaming

Kafka - Questo server non è il leader per quella partizione argomento

Kafka Connect Modalità distribuita Il coordinatore del gruppo non è disponibile

Come inviare il risultato finale di aggregazione dei flussi kafka di una KTable con finestra temporale?

Gestire i messaggi non validi utilizzando l'API Streams di Kafka

Errore durante la creazione dell'argomento di Kafka: - fattore di replica maggiore rispetto ai broker disponibili

Come leggere i dati usando Kafka Consumer API dall'inizio?

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?

Kafka con. Net Client

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

comprendendo l'id del gruppo di consumatori

Kafka bootstrap-servers vs zookeeper in kafka-console-consumer

Conteggio Numero di messaggi memorizzati in un argomento di kafka

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)

Broker leader senza un errore di listener corrispondente in kafka

La chiave è richiesta come parte dell'invio di messaggi a Kafka?

Semplice incorporato Kafka con avvio a molla

Kafka elenco consumatori

Kafka recupero dei metadati del consumatore per gli argomenti non riuscito

Kafka in Docker non funziona

Che cosa significa "Riequilibrio" in Apache Kafka?

Spark Streaming: leggi e scrivi su Kafka argomento

Differenza tra session.timeout.ms e max.poll.interval.ms per Kafka 0.10.0.0 e versioni successive

Kafka Il consumatore ottiene la coppia valore-chiave

Elimina il messaggio dopo averlo consumato in KAFKA

Kafka e regole del firewall

Kafka ID gruppo predefinito del consumatore

Kafka10.1 heartbeat.interval.ms, session.timeout.ms e max.poll.interval.ms

Qual è la differenza tra kafka i valori di offset più recenti e più recenti

Kafka ERRORE consumatore console "Offset commit non riuscito sulla partizione"

Perché Kafka hanno prodotto INVALID_FETCH_SESSION_Epoch dopo l'aggiornamento a 1.1?

Apache Camel contro Apache Kafka

Come ottenere dati dal vecchio punto di offset in Kafka?

C'è un modo per eliminare tutti i dati da un argomento o eliminare l'argomento prima di ogni esecuzione?

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

Errore di Apache Kafka su windows - Impossibile trovare o caricare la classe principale QuorumPeerMain

Perché i consumatori di Kafka si connettono a Zookeeper ei produttori ottengono metadati dai broker?

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

errore durante l'avvio del broker kafka

Come faccio a eliminare un gruppo di consumatori Kafka per reimpostare gli offset?

Elenca tutti gli argomenti di kafka

Kafka 1.0 si ferma con errore FATAL SHUTDOWN. La directory dei registri non è riuscita

Kafka + Zookeeper: impossibile stabilire la connessione al nodo -1. Il broker potrebbe non essere disponibile

Backup/ripristino di kafka e zookeeper

Integrazione di Spark Structured Streaming con il registro degli schemi Confluent

Come riavviare correttamente il server kafka?

Come verificare se ZooKeeper è in esecuzione o attivo dal prompt dei comandi?

Zookeeper è un must per Kafka?

zookeeper non è un'opzione riconosciuta quando si esegue kafka-console-consumer.sh

Apache Kafka vs Apache Storm

Quali sono i vantaggi e gli svantaggi di Kafka rispetto ad Apache Pulsar

Come creare un argomento in Kafka attraverso Java

Kafka: Ottieni l'host broker da ZooKeeper

Lettura descrittore artefatto non riuscita: IntelliJ

Kafka autenticazione del guardiano dello zoo SASL

Ottenuto KeeperException a livello di utente durante l'elaborazione

Come preparare i dati in un formato LibSVM da DataFrame?

Errore dell'encoder durante il tentativo di mappare la riga del frame di dati sulla riga aggiornata

Encoder per il tipo di riga Spark set di dati

Purge Kafka Topic

Come possiamo creare un argomento in Kafka dal IDE usando l'API

Errore di esempio di Apache Kafka: impossibile inviare il messaggio dopo 3 tentativi

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

Come decidere le dimensioni del Cluster Kafka

Kafka: impossibile inviare un messaggio a un server remoto utilizzando Java

Java, Come ottenere il numero di messaggi in un argomento in Apache kafka

Kafka QuickStart, pubblicizzato.Host.name dà kafka.common.LeaderNotAvailableException

Cosa determina l'offset del consumatore Kafka?

Errore durante la creazione degli argomenti di Kafka - Fattore di replica maggiore dei broker disponibili

Come eliminare un argomento in Apache kafka