kser 0.8.19

librdkafka

您可以选择使用confluent-kafka：

$ pip install kser[confluent]

卡夫卡Python

您可以选择纯python库kafka-python：

$ pip install kser[pykafka]

http

还有一个轻量级版本使用http理想来生成消息（不推荐使用）

$ pip install kser[http]

加密数据

可以使用libsodium加密kafka队列中的消息。

$ pip install kser[crypto]

您可以使用prometheus格式导出度量：

$ pip install kser[prometheus]

一些环境变量允许管理导出器：

默认情况下，导出器仅定义了两个度量，这只是一个示例。好的 实现自己的方法是重写触发器方法（前缀为“u”），如下例所示：

fromkserimportKSER_METRICS_ENABLEDfromprometheus_clientimportCounterfromkser.entryimportEntrypointMY_METRIC=Counter('kser_my_metric','a usefull metric')classMyEntrypoint(Entrypoint):def_run(self):ifKSER_METRICS_ENABLED=="yes":MY_METRIC.inc()returnself.run()

另请参见：

prometheus_client documentation

Documentation of the python Prometheus client

OpenTracing支持

您可以使用opentracing和Jaeger来跟踪操作和任务：

$ pip install kser[opentracing]

可以使用环境变量设置配置：

Environment variable	Default value
JAEGER_HOST	localhost

另请参见：

Opentracing support with Jaeger

Kser documentation