typeable/katip-kafka

Name: katip-kafka

Owner: TypeableIO

Description: Kafka backend for Katip

Created: 2018-03-01 10:07:57.0

Updated: 2018-04-28 11:37:33.0

Pushed: 2018-04-28 06:54:41.0

Homepage: null

Size: 4

Language: Haskell

GitHub Committers

UserMost Recent Commit# Commits

Other Committers

UserEmailMost Recent Commit# Commits

README

How to use


Record = simpleRecord "myapp.logs" UnassignedPartition
ops = brokersList [ BrokerAddress "kafka" ] <> compression Lz4
a <- kafkaScribe toRecord props DebugS V3 >>= either throwIO return
<- initLogEnv "myapp" (Environment "devel") >>=
gisterScribe "kafka" kafka defaultScribeSettings
lly (runMyApp env) $ closeScribes env
This work is supported by the National Institutes of Health's National Center for Advancing Translational Sciences, Grant Number U24TR002306. This work is solely the responsibility of the creators and does not necessarily represent the official views of the National Institutes of Health.