Feat support schema

openmessaging-api/src/main/java/io/openmessaging/api/MessageBuilder.java

@@ -28,55 +28,55 @@ public interface MessageBuilder<T> {
  /**
  * Used for set topic.
  * @param topic message topic
- * @return
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withTopic(String topic);
+ MessageBuilder<T> withTopic(String topic);
 
  /**
  * Used for message key.
  *
  * @param key message key
- * @return
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withKey(String key);
+ MessageBuilder<T> withKey(String key);
 
  /**
  * Used for set message tags.
  *
- * @param tags
- * @return
+ * @param tags message tags
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withTags(String tags);
+ MessageBuilder<T> withTags(String tags);
 
  /**
  * Used for set message sharding key.
  *
- * @param shardingKey
- * @return
+ * @param shardingKey message shardingKey
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withShardingKey(String shardingKey);
+ MessageBuilder<T> withShardingKey(String shardingKey);
 
  /**
  * Used for set user properties.
  *
- * @param key
- * @param value
- * @return
+ * @param key the key of user property
+ * @param value the value of user property
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withProperty(final String key, final String value);
+ MessageBuilder<T> withProperty(final String key, final String value);
 
  /**
  * Used for set message body.
  *
  * @param t object need to be serialized.
- * @return
+ * @return {@link MessageBuilder}
  */
- MessageBuilder withValue(T t);
+ MessageBuilder<T> withValue(T t);
 
  /**
  * Get the topic which this {@code MessageBuilder} belongs to.
  *
- * @return
+ * @return message topic
  */
  String getTopic();
 

openmessaging-api/src/main/java/io/openmessaging/api/PullConsumer.java

@@ -69,15 +69,6 @@ interface TopicPartitionChangeListener {
  */
  List<Message> poll(long timeout);
 
- /**
- * Fetch Objects for the topics or partitions specified using assign API. It is an error to not have subscribed to
- * any topics or partitions before polling for data.
- *
- * @param timeout in millisecond
- * @return
- */
- <T> List<GenericMessage<T>> pollGenericMessages(long timeout);
-
  /**
  * Overrides the fetch offsets that the consumer will use on the next {@link #poll(long)} }. If this API is invoked
  * for the same message queue more than once, the latest offset will be used on the next poll(). Note that you may