apache-kafka

8calore

3risposta

rimozione di un gruppo di consumatori kafka in zookeeper

Sto usando kafka_2.9.2-0.8.1.1 con zookeeper 3.4.6. Esiste un programma di utilità in grado di rimuovere automaticamente un gruppo di utenti da zookeeper? O posso semplicemente rimuovere tutto sotto/c

16calore

1risposta

Possiamo avere una forte capacità di routing con Apache Kafka simile a RabbitMq?

Stiamo provando a valutare Kafka e sostituire Rabbit Mq nel nostro software. Sappiamo i vantaggi di Kafka in termini di RabbitMq rispetto al consumo offline, enorme persistenza, prestazioni eccellenti

5calore

1risposta

Come posso produrre messaggi con l'API di Kafka 8.2 in Java?

Sto provando a lavorare con l'API di kafka in java. Sto usando la seguente dipendenza di Maven: <dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <

21calore

1risposta

Sia chiave è richiesto come parte del messaggio che trasmette in Kafka

KeyedMessage<String, byte[]> keyedMessage = new KeyedMessage<String, byte[]>(request.getRequestTopicName(),SerializationUtils.serialize(message)); producer.send(keyedMessage); Attualmente, vi mando un

9calore

2risposta

Streaming di dati da Kafka a Cassandra in tempo reale

Qual è il modo migliore per scrivere la data da Kafka a Cassandra? Mi aspetterei che fosse un problema risolto, ma non sembra esserci un adattatore standard. Un sacco di gente sembra usare Storm per l

19calore

3risposta

Strategia efficace per evitare i messaggi duplicati nel consumatore apache kafka

Ho studiato apache kafka da un mese. Sono tuttavia, bloccato ad un punto ora. Il mio caso d'uso è che ho due o più processi di consumo in esecuzione su macchine diverse. Ho eseguito alcuni test in cui

6calore

2risposta

Come modificare l'offset iniziale per argomento?

È possibile modificare l'offset iniziale per un nuovo argomento? Vorrei creare un nuovo argomento e iniziare a leggere dall'offset 10000. Come?

6calore

1risposta

Impossibile comunicare con il server kafka utilizzando kafka Producer API

Ho impostato kafka su un singolo nodo e ho avviato zookeeper e anche kafka server. L'ho testato per produttore interno e consumer su console e funziona bene. Ma quando sto facendo funzionare un utente

28calore

3risposta

modifica del periodo di conservazione kafka durante il runtime

Con Kafka 0.8.1.1, come posso modificare il tempo di conservazione del registro mentre è in esecuzione? Il documentation dice la proprietà è , ma cercando di cambiarlo usando kafka-topics.sh restituis

6calore

2risposta

org.apache.spark.SparkException: Task non serializzabile

Questo è un esempio di codice di lavoro: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> li