apache-kafka

9calore

1risposta

Confluent Piattaforma: Soggetti schema Registro

Lavorare con Confluent Platform, la piattaforma offerta dai creatori di Apache Kafka, e ho una domanda: Nella documentazione del Schema Registry API Reference, accennano l'astrazione di un "Oggetto" .

9calore

1risposta

Chiarificazione operazioni di offset API Kafka Java

Sto provando a utilizzare l'API consumer di basso livello per gestire gli offset manualmente, con l'ultimo kafka_2.10-0.8.2.1. Per verificare che gli offset che ho commesso/letto da Kafka siano corret

9calore

3risposta

Impossibile avviare il server Zookeeper - Kafka Setup

Sto provando a configurare Kafka facendo riferimento alla guida di avvio rapido sulla pagina apache kafka e mentre si avvia il server zookeeper si blocca in questo passaggio ... Apprezzeremmo se qualc

5calore

2risposta

aborting kafka riassegna partizione azione

Sto usando kafka 0.8.2 & uno dei miei server kafka è morto (non c'è modo di recuperare i dati sui dischi). C'è un argomento, con la replica di 1, con una delle partizioni sul server morto. Ho pensato

7calore

1risposta

Come usare Apache kafka con Spring mvc? È possibile?

Sono un principiante con apache kafka e cerco di imparare confluenza - kafka - riposo - utils, tuttavia mi confondo con come posso usarlo. Durante la ricerca ho trovato questa documentazione https://s

6calore

2risposta

Kafka più utenti per una partizione

Ho un produttore che scrive messaggi su un argomento/partizione. Per mantenere l'ordine, vorrei andare con una singola partizione e voglio che 12 consumatori leggano tutti i messaggi da questa singola

5calore

6risposta

Impossibile creare SparkContext

Sto testando Spark in spark-shell con codice scala. Sto costruendo il prototipo per usare Kafka e Spark. Ho eseguito il spark-shell come di seguito. spark-shell --jars ~/spark/external/kafka-assembly/

5calore

1risposta

kafka: cosa significano "soTimeout", "bufferSize" e "minBytes" per SimpleConsumer?

Sto usando Kafka 0.8.2.1 SimpleConsumer. Qualcuno potrebbe chiarire il significato di alcuni parametri di configurazione per SimpleConsumer e FetchRequestBuilder? A meno di leggere il codice sorgente

5calore

1risposta

Apache Spark-Kafka.TaskCompletionListenerException & KafkaRDD $ KafkaRDDIterator.close NPE sul cluster locale (Modalità client)

Il mio codice di streaming spark funziona perfettamente su eclipse IDE. Ma quando lo eseguo su un cluster spark locale dà org.apache.spark.util.TaskCompletionListenerException. Anche su spark-submit i

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