Mireczki szybkie pytanie: w mini serwisie uruchomionym za pośrednictwem node.js korzystam z kafki (kafka-node) w taki sposób, że z konkretnego topicu czytam eventy.
W momencie startu serwisu, gdy na kafce nie ma topicu który chcę obserwować (bo np. serwis który dany topic tworzy wstał później) dostaję error o treści:
ERROR: TopicsNotExistError: The topic(s) kafkaTopic3 do not exist
Chciałbym zastosować tam w takim wypadku próbę jakiegoś reconnecta bo niestety z automatu to się
W momencie startu serwisu, gdy na kafce nie ma topicu który chcę obserwować (bo np. serwis który dany topic tworzy wstał później) dostaję error o treści:
ERROR: TopicsNotExistError: The topic(s) kafkaTopic3 do not exist
Chciałbym zastosować tam w takim wypadku próbę jakiegoś reconnecta bo niestety z automatu to się
@Generyczny_nick: glupoty popisalem mireczku, tutaj masz 100% pewne soluszyn ( ͡° ͜ʖ ͡°)
const kafka = require('kafka-node');
const Consumer = kafka.Consumer;
const today = new Date();
let i = 0;
const work = () => {
console.log('Work ' + i);
const client = new kafka.KafkaClient({ kafkaHost: "localhost:9092", connectTimeout: 1000 }); // 15s timeout
const consumer = new Consumer(client, [{ topic: "kafkaTopic3", time: -1, maxNum: 1 }]);
consumer.on('message',
const kafka = require('kafka-node');
const Consumer = kafka.Consumer;
const today = new Date();
let i = 0;
const work = () => {
console.log('Work ' + i);
const client = new kafka.KafkaClient({ kafkaHost: "localhost:9092", connectTimeout: 1000 }); // 15s timeout
const consumer = new Consumer(client, [{ topic: "kafkaTopic3", time: -1, maxNum: 1 }]);
consumer.on('message',
@4191727801:
dzięki mireczku, po dostosowaniu do swoich potrzeb działa bardzo fajnie.
Wirtualne piwerko dla Ciebie ( ͡~ ͜ʖ ͡°)
dzięki mireczku, po dostosowaniu do swoich potrzeb działa bardzo fajnie.
Wirtualne piwerko dla Ciebie ( ͡~ ͜ʖ ͡°)
Dawno mi tak nic krwi nie napsuło jak react-redux