apache-kafka

8calore

1risposta

Kafka fallimento singolo utente in un gruppo

Sono nelle fasi iniziali di esplorazione Kafka, la versione 0.8.1.1. Sono gestire con successo il Gruppo Esempio dei consumatori, con più partizioni ed i suoi messaggi distribuzione tra i consumatori

5calore

1risposta

L'encoder predefinito Apache Kafka non funziona

Utilizzo la versione beta di Kafka 0.8 e sto solo cercando di mandare oggetti diversi, serializzarli con il mio codificatore e inviarli a una configurazione di broker esistente. Per ora sto cercando d

64calore

11risposta

In esecuzione in LeaderNotAvailableException quando si utilizza Kafka 0.8.1 con Zookeeper 3.4.6

Ho installato la versione stabile di kafka (0.8.1 con 2.9.2 Scala) come da sito Web e la eseguo con un insieme di zookeeper di 3 nodi (3.4 0,6). Ho cercato di creare un argomento di prova, ma continuo

5calore

1risposta

La stessa istanza Zookeeper può essere utilizzata dal numero di servizi?

Un'installazione di un Zookeeper è sufficiente per essere utilizzata dai cluster Hadoop Kafka e Storm? Voglio distribuire tutto in un ambiente di test e provare a giocare con queste tecnologie, posso

9calore

2risposta

perché il file .index esiste nella directory kafka-log?

Ho appena creato un nuovo argomento, non ho ancora prodotto alcun messaggio. Un file chiamato "00000000000000000000.index" creato nella directory "/ tmp/kafka-logs-1/topicname-0 /", e la dimensione di

9calore

1risposta

Kafka: impossibile creare più utenti di streaming

Mi sono appena avviato e in esecuzione con Kafka 0.8 beta 1. Ho un esempio davvero semplice attivo e funzionante, il problema è che posso far funzionare solo un messaggio, non diversi. Cioè, il metodo

8calore

3risposta

Come ottenere multi-tenancy nel contesto di Kafka e tempesta?

Quali sono le migliori pratiche, per la creazione di un'app multi-tenant nel contesto di Kafka e tempesta? Ad esempio: creazione dell'argomento per ciascun tenant e consumo di beccuccio multi-argoment

7calore

3risposta

Apache Kafka - KafkaStream su argomento/partizione

Scrivo Kafka Consumer per applicazioni distribuite ad alta velocità ad alto volume. Ho solo un argomento, ma i messaggi in arrivo sono molto alti. Avere più partizioni che servono più consumatori sare

8calore

2risposta

Apache Storm java.nio.channels.ClosedChannelException: null

Stiamo cercando di utilizzare Apache Storm per l'elaborazione di grandi quantità di messaggi (falsi). Esempio Messaggio: "{"clientName":"Sergey Bakulin","sum":12925,"group":"property","suspicious":fal

47calore

5risposta

Kafka: Zookeeper è un must?

In Kafka, vorrei utilizzare solo un singolo broker, un singolo argomento e una singola partizione con un produttore e più utenti (ogni consumatore riceve la propria copia dei dati dal broker). Detto q