tracer0tong / kafkalogrus

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

Fix partition key bug #5

Closed thomasxnguy closed 6 years ago

thomasxnguy commented 6 years ago

Change partition key to take random value from entry.Time instead of entry.Data["time"] which always return null before formatting.

This bug prevents logs to be evenly distributed between topic's partitions.