kafka-consumer-api

10calore

1risposta

Does commitOffsets sul blocco consumer di alto livello?

Nel client Java (http://kafka.apache.org/documentation.html#highlevelconsumerapi), commitOffsets sul blocco consumer di alto livello fino a quando gli offset non vengono eseguiti correttamente, oppure

6calore

1risposta

Impossibile comunicare con il server kafka utilizzando kafka Producer API

Ho impostato kafka su un singolo nodo e ho avviato zookeeper e anche kafka server. L'ho testato per produttore interno e consumer su console e funziona bene. Ma quando sto facendo funzionare un utente

7calore

2risposta

sessioni di consumo kafka timeout

Abbiamo un'applicazione che un utente legge un messaggio e il thread fa un certo numero di cose, inclusi gli accessi al database prima che un messaggio venga prodotto su un altro argomento. Il tempo t

21calore

1risposta

Sia chiave è richiesto come parte del messaggio che trasmette in Kafka

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(),SerializationUtils.serialize(message)); producer.send(keyedMessage); Attualmente, vi mando un

12calore

2risposta

Algoritmo di riequilibrio dei consumi di Kafka

Qualcuno può dirmi qual è l'algoritmo di riequilibrio per i consumatori di Kafka? Mi piacerebbe capire in che modo il conteggio delle partizioni e i thread dei consumatori influiscono su questo. Grazi

7calore

1risposta

argomento Kafka vs partizione

Vorrei sapere qual è la differenza tra argomento argomento semplice argomento &. Come per la mia comprensione per bilanciare il carico, argomento è stato partizionato, Ogni messaggio avrà offset & con

20calore

1risposta

Come funziona il riequilibrio del consumatore in Kafka?

Quando un nuovo consumatore/bricolage viene aggiunto o abbassa, Kafka attiva un'operazione di ribilanciamento. Kafka sta riequilibrando un'operazione di blocco. I consumatori di Kafka sono bloccati me

10calore

3risposta

Errore nella creazione argomento Kafka: - fattore di replica più grande di broker disponibili

Sto cercando di creare un argomento Kafka tramite AdminCommand utilizzando sottostante Codice Source ZkClient zkClient = new ZkClient(kafkaHost, 10000, 10000, ZKStringSerializer$.MODULE$); AdminU