We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 54f8dcf commit fde331cCopy full SHA for fde331c
1 file changed
openmessaging-api/src/main/java/io/openmessaging/api/PullConsumer.java
@@ -69,15 +69,6 @@ interface TopicPartitionChangeListener {
69
*/
70
List<Message> poll(long timeout);
71
72
- /**
73
- * Fetch Objects for the topics or partitions specified using assign API. It is an error to not have subscribed to
74
- * any topics or partitions before polling for data.
75
- *
76
- * @param timeout in millisecond
77
- * @return
78
- */
79
- <T> List<GenericMessage<T>> pollGenericMessages(long timeout);
80
-
81
/**
82
* Overrides the fetch offsets that the consumer will use on the next {@link #poll(long)} }. If this API is invoked
83
* for the same message queue more than once, the latest offset will be used on the next poll(). Note that you may
0 commit comments