search

tracer0tong / kafkalogrus

Modified version of Kafka hook for Logrus
Apache License 2.0
7 stars 10 forks source link

Should partitionKey be entry.Time instead of entry.Data["time"].(time.Time)? #3

Closed YoungWing closed 6 years ago

thomasxnguy commented 6 years ago

I have created a PR for this. This bug prevents logs to be evenly distributed between topics partitions since they are sent always to the same one.

tracer0tong commented 6 years ago

Thanks @thomasxnguy, I have merged your PR.