apache-kafka

12calore

2risposta

kafka-server-stop.sh non funziona quando Kafka ha iniziato dallo script Python

Dopo aver distribuito alcune istanze di Apache Kafka su nodi remoti, ho riscontrato un problema con lo script kafka-server-stop.sh che fa parte dell'archivio di Kafka. Di default contiene: #!/bin/sh

5calore

2risposta

nimbus tempesta non si avvia: ottenere sotto errore

$ storm nimbus Traceback (most recent call last): File "/home/chefsolo/apache-storm-0.9.1-incubating/bin/storm", line 455, in <m odule> main() File "/home/chefsolo/apache-

5calore

1risposta

Come leggere gli argomenti di Kafka in un determinato intervallo di tempo?

Ho bisogno di leggere i messaggi in un intervallo di tempo specificato da un argomento di Kafka. La soluzione che posso pensare è quella di trovare prima l'offset più grande per l'inizio dell'interval

6calore

4risposta

Produce Kafka messaggio a partizione selezionata

Secondo la documentazione Kafka: Il produttore è responsabile della scelta di quale messaggio da assegnare a quale partizione all'interno del tema. Quindi la mia domanda principale è: Come posso invia

5calore

2risposta

Integrazione Camel Kafka

Recentemente ho notato che Camel ora ha il suo componente per Kafka, quindi ho deciso di dargli un vortice. ho deciso di provare un bel semplice file -> topic Kafka come segue ... <route> <from

5calore

6risposta

Kafka nodo, dei consumatori ha ottenuto sempre i vecchi messaggi

im utilizzando il modulo di Kafka nodi https://github.com/SOHU-Co/kafka-node e ogni volta quando si riavvia dei consumatori hanno ottenuto tutti i messaggi vecchi, im utilizzando il sistema round robi

8calore

1risposta

WebSocket si chiude dopo 1000 messaggi

Sto scrivendo un'app per trasmettere messaggi al browser da Apache Kafka utilizzando un WebSocket. Quando il server non consuma i messaggi per un po 'e l'offset rimane indietro, il websocket si chiude

5calore

1risposta

Come creare Kafka ZKStringSerializer in Java?

Nella ricerca di come creare un argomento Kafka tramite l'API, ho trovato questo esempio a Scala: import kafka.admin.AdminUtils import kafka.utils.ZKStringSerializer import org.I0Itec.zkclient.ZkCli

7calore

1risposta

Kafka - Il modo più semplice per ottenere l'ultima correzione

Sto costruendo un'applicazione che consente di aggiungere e rimuovere in modo dinamico gli abbonamenti agli argomenti di kafka. Quando viene aggiunta una sottoscrizione argomento, desidero eseguire un

5calore

1risposta

L'utente Java di Kafka funziona solo per localhost e non riesce per il server remoto

Ho lavorato con Kafka per due mesi e ho utilizzato questo codice per consumare messaggi localmente. Recentemente ho deciso di distribuire Zookeeper e Kafka e tutto sembra funzionare bene. Il mio probl