kafka-producer-api

7calore

2risposta

Consegna garantita di più messaggi al cluster Kafka

Se pubblico diversi messaggi di seguito in un cluster Kafka (utilizzando lo new Producer API), ottengo un Future dal produttore per ciascun messaggio. Ora, supponendo che abbia configurato il mio prod

5calore

3risposta

Kafka 0.10 Java Client TimeoutException: batch contenente 1 record (i) scaduti

Ho un singolo nodo, multi (3) setup di Zookeeper/Kafka broker. Sto usando il client Java 0.10 di Kafka. ho scritto seguendo semplici remoto (su un server diverso da Kafka) Produttore (nel codice ho so

5calore

4risposta

Come creare argomenti in apache kafka?

Qual è la strada migliore per creare argomenti in kafka? Quante repliche/partizioni da definire quando creiamo gli argomenti? Nella nuova API di produzione, quando provo a pubblicare un messaggio su u

8calore

2risposta

Kafka genera java.nio.channels.ClosedChannelException

Quando provo a utilizzare i messaggi dal server kafka che è ospitato in ec2 con lo strumento console kafka (V 0.9.0.1, penso che usi le vecchie API consumer) Ottengo l'eccezione seguente . Come posso

6calore

4risposta

Campo di lettura dell'errore 'topic_metadata' in Kafka

Sto provando a collegarmi al mio broker su aws con auto.create.topics.enable = true nel mio file server.properties. Ma quando sto cercando di connettermi al broker usando il produttore client Java, st

6calore

2risposta

Temi, partizioni e chiavi

Sto cercando qualche chiarimento sull'argomento. Nella documentazione di Kafka ho trovato quanto segue: Kafka fornisce solo un ordine totale sui messaggi all'interno di una partizione, non tra diverse

6calore

1risposta

Il produttore Kafka non è in grado di aggiornare i metadati dopo qualche tempo

Ho un ambiente kafka che ha 3 brokers e 1 zookeeper. Avevo spinto circa> 20K messaggio nel mio argomento. Apache Storm sta calcolando i dati in argomento che viene aggiunto dal produttore. Dopo poche

5calore

1risposta

Come si imposta la dimensione dei messaggi in Kafka?

Attualmente sto usando Kafka 0.9.0.1. Secondo alcune fonti che ho trovato, il modo per impostare le dimensioni dei messaggi è modificare i seguenti valori chiave in server.properties. message.max.byte

5calore

1risposta

Il metodo poll() di Kafka Consumer viene bloccato

Sono nuovo di Kafka 0.9 e testando alcune funzionalità ho realizzato uno strano comportamento nel consumer implementato in Java (KafkaConsumer). Il broker Kafka si trova in una macchina esterna Ambari

15calore

4risposta

Come verificare se Kafka Server è in esecuzione?

Desidero verificare se il server kafka è in esecuzione o meno prima di avviare processi di produzione e consumo. E 'in ambiente Windows ed ecco il codice del mio server Kafka in Eclipse ... Properties