Possible doco extension

[corsc]

I am writing from Go to Kafka.

I was getting error messages like:
Couldn't decode protobuf: #<RuntimeError: CodedInputStream encountered a malformed varint.>.
And:
Couldn't decode protobuf: #<RuntimeError: Protocol message end-group tag did not match expected tag.>.
And even incorrect data sometimes. My int64 was coming through with the wrong value.

Turns out the issue not setting the serializers to the appropriate values.
In my case it was:

input {
	kafka {
		key_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
		value_deserializer_class => "org.apache.kafka.common.serialization.ByteArrayDeserializer"
	}
}

Perhaps someone more knowledgeable then I could add some comments to the documentation to help newbies like me?
Cheers

[IngaFeick]

Thank you, Corey, much appreciated! I will add that. Cheers!

[IngaFeick]

@corsc I tested this and I would like to very much apologize to you for not having pointed this out in the documentation earlier. I'm using a custom version of the kafka plugin and I didn't run into this yet. 😬 PR is written. Thanks again!

[corsc]

No worries and definitely no need to apologise. Thanks again