Allow null keys in the Utf8Deserializer

salesforce / storm-dynamic-spout

A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.

BSD 3-Clause "New" or "Revised" License

41 stars 13 forks source link

Allow null keys in the Utf8Deserializer #98

Closed stanlemon closed 6 years ago

stanlemon commented 6 years ago

Currently when publishing a message with a null key this deserializer will throw a NullPointerException. This PR corrects that behavior, thus allowing for null keys and it also addresses null values by returning null instead of a Values object containing null.

Crim commented 6 years ago

Maybe update the CHANGELOG, looks good :shipit: