tx7do / kratos-transport

kratos transport layer extension
MIT License
348 stars 95 forks source link

kafka trace 集成到kratos中没有生效 #30

Closed lswencn closed 1 year ago

lswencn commented 1 year ago

是这样写的不?

srv := kafka.NewServer(
        kafka.WithAddress(c.Kafka.Addrs),
        kafka.WithCodec(encoding.GetCodec("json")),
        kafka.WithTracerProvider(tp, "kafka-tracer"),
    )
tx7do commented 1 year ago

没错的呀

lswencn commented 1 year ago

jaeger没有收到消息。。。。。。蛋疼了

tx7do commented 1 year ago

我增加了示例代码,你自己看看。