Fluent-logger кафка - PullRequest
Новая
       80

Fluent-logger кафка

0 голосов
/ 05 мая 2020

Здравствуйте, я пытаюсь научиться регистрировать действия из моего приложения с помощью fluent-logger. Мне удалось отправить его в файл, используя пример, приведенный на их странице. Однако я хотел бы перенаправить вывод в kafka (плагин fluentd kafka2), а из kafka сохранить его в базе данных cassandra. Я новичок в этой области, поэтому буду очень признателен за любые предложения. Я использую nodejs с фреймворком express. Код на странице: 

const logger = require('fluent-logger');
const app = express();

// The 2nd argument can be omitted. Here is a default value for options.
logger.configure('fluentd.test', {
  host: 'localhost',
  port: 24224,
  timeout: 3.0,
  reconnectInterval: 600000 // 10 minutes
});

app.get('/', function(request, response) {
  logger.emit('follow', {from: 'userA', to: 'userB'});
  response.send('Hello World!');
});

Теперь я хотел бы отправить это сообщение журнала в kafka с помощью topi c, а затем из kafka в Cassandra

...