Open funkygao opened 8 years ago
What version of the Scala implementation are you basing this on? The schema I am using was definitely the schema around 0.8.2.
Also, it looks like Travis didn't run CI on this pull request. This issue should be fixed now. Can you rebase this PR and try again?
in java/scala kafka implementation, the Timestamp of a consumer is string instead of int64