apache-kafka

7calore

2risposta

Kafka -> Flink DataStream -> MongoDB

Voglio configurare Flink in modo che possa trasformare e reindirizzare i flussi di dati da Apache Kafka a MongoDB. A scopo di test sto costruendo in cima all'esempio flink-streaming-connectors.kafka (

mongodb hadoop apache-kafka apache-flink 2016-02-02

---

10calore

4risposta

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

Sto usando il consumer di alto livello Python per Kafka e voglio sapere gli ultimi offset per ogni partizione di un argomento. Tuttavia non riesco a farlo funzionare. from kafka import TopicPartition

python apache-kafka kafka-consumer-api kafka-python 2016-02-16

---

11calore

9risposta

kafka ottiene il conteggio delle partizioni per un argomento

Come posso ottenere il numero di partizioni per qualsiasi argomento di kafka dal codice. Ho ricercato molti collegamenti ma nessuno sembra funzionare. Citando alcuni: http://grokbase.com/t/kafka/users

java apache-kafka 2016-02-16

---

9calore

4risposta

Kafka supporta la richiesta di messaggistica di risposta

Sto indagando su Kafka 9 come progetto per hobby e ho completato alcuni esempi di tipo "Hello World". Ho dovuto pensare alle applicazioni di Real World Kafka basate sulla richiesta di messaggistica di

apache-kafka kafka-consumer-api kafka-producer-api mom 2016-02-21

---

10calore

1risposta

possono più utenti kafka che leggono lo stesso messaggio nella partizione

stiamo pianificando di scrivere un utente kafka (java) che legge la coda di kafka per eseguire un'azione contenuta nel messaggio. Poiché i consumatori eseguono autonomamente, il messaggio verrà elabor

apache-kafka kafka-consumer-api 2016-02-22

---

7calore

2risposta

Kafka CommitFailedException eccezione consumatore

Dopo creare più consumatori (usando Kafka 0.9 Java API) e ciascun thread iniziato, sto ottenendo la seguente eccezione Consumer has failed with exception: org.apache.kafka.clients.consumer.CommitFaile

java apache-kafka kafka-consumer-api 2016-02-26

---

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

java apache-kafka kafka-consumer-api kafka-producer-api 2016-02-29

---

9calore

2risposta

Query argomento Kafka per record specifici

Esiste un modo elegante per interrogare un argomento di Kafka per un record specifico? L'API REST che sto sviluppando ottiene un ID e deve cercare i record associati a quell'ID in un argomento di Kafk

apache-kafka 2016-02-29

---

5calore

2risposta

Come gestire il fallimento di Kafka Cluster

Implementeremo un sistema Kafka Publish Subscribe. Ora, nel peggiore dei casi peggiori, se tutti i broker di kafka per un determinato argomento scendono, cosa succede? Ho provato questo ... l'editore

apache-kafka kafka-consumer-api 2016-03-03

---

5calore

3risposta

Come verificare che SSL funzioni per Kafka

Sono stato in grado di configurare SSL nei miei broker e client kafka e sono anche in grado di vedere che quando produciamo messaggi usando la porta 9093 che è la porta SSL i messaggi sono consumati d

ssl apache-kafka 2016-03-03

---