[STORM-2467] Encoding issues in Kafka consumer

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.1.0
• Fix Version/s: 2.0.0, 1.1.1, 1.2.0
• Component/s: storm-kafka
• Assignee: Marcus Thiesen
• Reporter: Marcus Thiesen
• Created: 11/Apr/17 15:01
• Updated: 03/Jul/17 15:11
• Resolved: 14/Apr/17 06:03

Description

The StringScheme of the storm-kafka consumer does not set an explicit charset in all cases, which leads to messages being decoded in the environment specific default charset.

I have a PR for that to fix it
https://github.com/apache/storm/pull/2055

Issue Links

• links to: GitHub Pull Request #2055