Skip to content

Commit 8045676

Browse files
committed
fix(sample) fix the method cannot found error
1 parent da1a8ed commit 8045676

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

openmessaging-api-samples/src/main/java/io/openmessaging/samples/consumer/GenericPullConsumerApp.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -57,7 +57,7 @@ public void run() {
5757
consumer.assign(topicPartitions);
5858
consumer.start();
5959

60-
List<GenericMessage<MessageSample>> messages = consumer.batchPoll(1000);
60+
List<GenericMessage<MessageSample>> messages = consumer.pollGenericMessages(1000);
6161
for (GenericMessage<MessageSample> message : messages) {
6262
System.out.println("Received message: " + message.getValue());
6363
}

0 commit comments

Comments
 (0)