We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 7377f00 commit b527b98Copy full SHA for b527b98
financial/springboot-backend/src/main/java/oracleai/kafka/OrderConsumerService.java
@@ -56,15 +56,6 @@ public void runConsumer() {
56
}
57
58
59
- public void consumeMessages() {
60
- consumer.subscribe(topics);
61
- ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(100));
62
- //process records
63
- Connection connection = consumer.getDBConnection();
64
- if(somethingWentWrong) connection.rollback();
65
- else consumer.commitSync();
66
- }
67
-
68
@Override
69
public void close() {
70
if (this.consumer != null) {
0 commit comments