Skip to content

Commit

Permalink
Remove SerializableDeserializer for binary compatibility with 1.0.x
Browse files Browse the repository at this point in the history
  • Loading branch information
Stig Rohde Døssing committed Mar 8, 2017
1 parent a5f73cd commit dc78c16
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 29 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -105,8 +105,8 @@ private Map<String, Object> setDefaultsAndGetKafkaProps(Map<String, Object> kafk

public static class Builder<K,V> {
private final Map<String, Object> kafkaProps;
private SerializableDeserializer<K> keyDeserializer;
private SerializableDeserializer<V> valueDeserializer;
private Deserializer<K> keyDeserializer;
private Deserializer<V> valueDeserializer;
private long pollTimeoutMs = DEFAULT_POLL_TIMEOUT_MS;
private long offsetCommitPeriodMs = DEFAULT_OFFSET_COMMIT_PERIOD_MS;
private int maxRetries = DEFAULT_MAX_RETRIES;
Expand Down Expand Up @@ -164,15 +164,15 @@ public Builder(Map<String, Object> kafkaProps, KafkaSpoutStreams kafkaSpoutStrea
/**
* Specifying this key deserializer overrides the property key.deserializer
*/
public Builder<K,V> setKeyDeserializer(SerializableDeserializer<K> keyDeserializer) {
public Builder<K,V> setKeyDeserializer(Deserializer<K> keyDeserializer) {
this.keyDeserializer = keyDeserializer;
return this;
}

/**
* Specifying this value deserializer overrides the property value.deserializer
*/
public Builder<K,V> setValueDeserializer(SerializableDeserializer<V> valueDeserializer) {
public Builder<K,V> setValueDeserializer(Deserializer<V> valueDeserializer) {
this.valueDeserializer = valueDeserializer;
return this;
}
Expand Down

This file was deleted.

0 comments on commit dc78c16

Please sign in to comment.