http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serde.html index 81b943f..1d158db 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serde.html @@ -2,15 +2,15 @@ - -Serde (clients 0.10.0.0 API) - + +Serde (kafka 0.10.0.0 API) + @@ -90,7 +90,7 @@ A class that implements this interface is expected to have a constructor with no parameter.
All Superinterfaces:
-
java.lang.AutoCloseable, java.io.Closeable
+
AutoCloseable, Closeable
All Known Implementing Classes:
@@ -99,7 +99,7 @@

public interface Serde<T>
-extends java.io.Closeable
+extends Closeable
The interface for wrapping a serializer and deserializer for the given data type.
@@ -127,7 +127,7 @@ extends java.io.Closeable void -configure(java.util.Map<java.lang.String,?> configs, +configure(Map<String,?> configs, boolean isKey)
Configure this class, which will configure the underlying serializer and deserializer.
@@ -161,7 +161,7 @@ extends java.io.Closeable http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html index baffc4f..3552cfb 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html @@ -2,15 +2,15 @@ - -Serdes.ByteArraySerde (clients 0.10.0.0 API) - + +Serdes.ByteArraySerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
    -
  • java.lang.Object
  • +
  • java.lang.Object
    • org.apache.kafka.common.serialization.Serdes.ByteArraySerde
    • @@ -95,7 +95,7 @@
    • All Implemented Interfaces:
      -
      java.io.Closeable, java.lang.AutoCloseable, Serde<byte[]>
      +
      Closeable, AutoCloseable, Serde<byte[]>
      Enclosing class:
      @@ -104,7 +104,7 @@

      public static final class Serdes.ByteArraySerde
      -extends java.lang.Object
      +extends Object
@@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html index 1562eaa..3ec5b01 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.ByteBufferSerde.html @@ -2,15 +2,15 @@ - -Serdes.ByteBufferSerde (clients 0.10.0.0 API) - + +Serdes.ByteBufferSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.ByteBufferSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<java.nio.ByteBuffer>
        +
        Closeable, AutoCloseable, Serde<ByteBuffer>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.ByteBufferSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.BytesSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.BytesSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.BytesSerde.html index 4a64ded..7be19cd 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.BytesSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.BytesSerde.html @@ -2,15 +2,15 @@ - -Serdes.BytesSerde (clients 0.10.0.0 API) - + +Serdes.BytesSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.BytesSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<org.apache.kafka.common.utils.Bytes>
        +
        Closeable, AutoCloseable, Serde<org.apache.kafka.common.utils.Bytes>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.BytesSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.DoubleSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.DoubleSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.DoubleSerde.html index 915871a..3be54df 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.DoubleSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.DoubleSerde.html @@ -2,15 +2,15 @@ - -Serdes.DoubleSerde (clients 0.10.0.0 API) - + +Serdes.DoubleSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.DoubleSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<java.lang.Double>
        +
        Closeable, AutoCloseable, Serde<Double>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.DoubleSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.IntegerSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.IntegerSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.IntegerSerde.html index 93e3e2f..0ebdfa9 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.IntegerSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.IntegerSerde.html @@ -2,15 +2,15 @@ - -Serdes.IntegerSerde (clients 0.10.0.0 API) - + +Serdes.IntegerSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.IntegerSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<java.lang.Integer>
        +
        Closeable, AutoCloseable, Serde<Integer>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.IntegerSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.LongSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.LongSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.LongSerde.html index 68569d2..f651df2 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.LongSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.LongSerde.html @@ -2,15 +2,15 @@ - -Serdes.LongSerde (clients 0.10.0.0 API) - + +Serdes.LongSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.LongSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<java.lang.Long>
        +
        Closeable, AutoCloseable, Serde<Long>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.LongSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.StringSerde.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.StringSerde.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.StringSerde.html index 6de86d0..d6e4b93 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.StringSerde.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.StringSerde.html @@ -2,15 +2,15 @@ - -Serdes.StringSerde (clients 0.10.0.0 API) - + +Serdes.StringSerde (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      -
    • java.lang.Object
    • +
    • java.lang.Object
      • org.apache.kafka.common.serialization.Serdes.StringSerde
      • @@ -95,7 +95,7 @@
      • All Implemented Interfaces:
        -
        java.io.Closeable, java.lang.AutoCloseable, Serde<java.lang.String>
        +
        Closeable, AutoCloseable, Serde<String>
        Enclosing class:
        @@ -104,7 +104,7 @@

        public static final class Serdes.StringSerde
        -extends java.lang.Object
        +extends Object
    @@ -138,8 +138,8 @@ extends java.lang.Object
  • -

    Methods inherited from class java.lang.Object

    -clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
  • +

    Methods inherited from class java.lang.Object

    +clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.html b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.html index 5628eb5..b414a96 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serdes.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serdes.html @@ -2,15 +2,15 @@ - -Serdes (clients 0.10.0.0 API) - + +Serdes (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
    @@ -260,7 +260,7 @@ extends java.lang.Object
    • serdeFrom

      -
      public static <T> Serde<T> serdeFrom(java.lang.Class<T> type)
      +
      public static <T> Serde<T> serdeFrom(Class<T> type)
    @@ -281,7 +281,7 @@ extends java.lang.Object @@ -290,7 +290,7 @@ extends java.lang.Object @@ -299,7 +299,7 @@ extends java.lang.Object @@ -308,7 +308,7 @@ extends java.lang.Object @@ -317,7 +317,7 @@ extends java.lang.Object http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/Serializer.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/Serializer.html b/0100/javadoc/org/apache/kafka/common/serialization/Serializer.html index 27a2711..66c4eda 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/Serializer.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/Serializer.html @@ -2,15 +2,15 @@ - -Serializer (clients 0.10.0.0 API) - + +Serializer (kafka 0.10.0.0 API) + @@ -90,7 +90,7 @@ A class that implements this interface is expected to have a constructor with no parameter.
    All Superinterfaces:
    -
    java.lang.AutoCloseable, java.io.Closeable
    +
    AutoCloseable, Closeable
    All Known Implementing Classes:
    @@ -99,7 +99,7 @@

    public interface Serializer<T>
    -extends java.io.Closeable
    +extends Closeable @@ -126,14 +126,14 @@ extends java.io.Closeable void -configure(java.util.Map<java.lang.String,?> configs, +configure(Map<String,?> configs, boolean isKey)
    Configure this class.
    byte[] -serialize(java.lang.String topic, +serialize(String topic, T data)  @@ -157,7 +157,7 @@ extends java.io.Closeable
    • configure

      -
      void configure(java.util.Map<java.lang.String,?> configs,
      +
      void configure(Map<String,?> configs,
                    boolean isKey)
      Configure this class.
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value
      @@ -171,7 +171,7 @@ extends java.io.Closeable
      • serialize

        -
        byte[] serialize(java.lang.String topic,
        +
        byte[] serialize(String topic,
                        T data)
        Parameters:
        topic - topic associated with data
        data - typed data
        Returns:
        serialized bytes
        @@ -189,9 +189,9 @@ extends java.io.Closeable
        multiple times.
        Specified by:
        -
        close in interface java.lang.AutoCloseable
        +
        close in interface AutoCloseable
        Specified by:
        -
        close in interface java.io.Closeable
        +
        close in interface Closeable
      http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html b/0100/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html index 74f41fa..e87d438 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/StringDeserializer.html @@ -2,15 +2,15 @@ - -StringDeserializer (clients 0.10.0.0 API) - + +StringDeserializer (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
      @@ -200,13 +200,13 @@ implements
    • configure

      -
      public void configure(java.util.Map<java.lang.String,?> configs,
      +
      public void configure(Map<String,?> configs,
                    boolean isKey)
      Description copied from interface: Deserializer
      Configure this class.
      Specified by:
      -
      configure in interface Deserializer<java.lang.String>
      +
      configure in interface Deserializer<String>
      Parameters:
      configs - configs in key/value pairs
      isKey - whether is for key or value
    @@ -216,11 +216,11 @@ implements
  • deserialize

    -
    public java.lang.String deserialize(java.lang.String topic,
    -                           byte[] data)
    +
    public String deserialize(String topic,
    +                 byte[] data)
    Specified by:
    -
    deserialize in interface Deserializer<java.lang.String>
    +
    deserialize in interface Deserializer<String>
    Parameters:
    topic - topic associated with the data
    data - serialized bytes
    Returns:
    deserialized typed data
  • @@ -234,11 +234,11 @@ implements close
     in interface Closeable
    Specified by:
    -
    close in interface java.lang.AutoCloseable
    +
    close in interface AutoCloseable
    Specified by:
    -
    close in interface Deserializer<java.lang.String>
    +
    close in interface Deserializer<String>
    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/org/apache/kafka/common/serialization/StringSerializer.html ---------------------------------------------------------------------- diff --git a/0100/javadoc/org/apache/kafka/common/serialization/StringSerializer.html b/0100/javadoc/org/apache/kafka/common/serialization/StringSerializer.html index 9051635..0ceb314 100644 --- a/0100/javadoc/org/apache/kafka/common/serialization/StringSerializer.html +++ b/0100/javadoc/org/apache/kafka/common/serialization/StringSerializer.html @@ -2,15 +2,15 @@ - -StringSerializer (clients 0.10.0.0 API) - + +StringSerializer (kafka 0.10.0.0 API) + @@ -83,7 +83,7 @@
    @@ -218,11 +218,11 @@ implements
  • serialize

    -
    public byte[] serialize(java.lang.String topic,
    -               java.lang.String data)
    +
    public byte[] serialize(String topic,
    +               String data)
    Specified by:
    -
    serialize in interface Serializer<java.lang.String>
    +
    serialize in interface Serializer<String>
    Parameters:
    topic - topic associated with data
    data - typed data
    Returns:
    serialized bytes
  • @@ -240,11 +240,11 @@ implements close
     in interface Closeable
    Specified by:
    -
    close in interface java.lang.AutoCloseable
    +
    close in interface AutoCloseable
    Specified by:
    -
    close in interface Serializer<java.lang.String>
    +
    close in interface Serializer<String>