hapijs + pino + kafka

app.js

const pino = require('pino')
const pkafka = require('pino-kafka')

// this can be from .env, via JSON.parse
const kafkaLogConfig = {
  "clientId":"some-producer1",
  "defaultTopic": "some-log-topic",
  "brokers":["some-host:9092"]
}
const streams = [{ stream: process.stdout, level: 'info' }]
if (kafkaLogConfig) {
  streams.push({ stream: pkafka(kafkaLogConfig) })
}
const logger = pino(
  {
    redact: [
      'req.headers.api-key',
    ]
  },
  pino.multistream(streams)
)
// ...
server.register([{
  plugin: require('hapi-pino'),
  options: {
    instance: logger
  }
}])