philipnee commented on code in PR #12862:
URL: https://github.com/apache/kafka/pull/12862#discussion_r1047889124
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEvent.java:
##########
@@ -20,10 +20,23 @@
* This is the abstract definition of the events created by the KafkaConsumer
API
*/
abstract public class ApplicationEvent {
+ public final Type type;
+
+ protected ApplicationEvent(Type type) {
+ this.type = type;
+ }
/**
* process the application event. Return true upon succesful execution,
* false otherwise.
* @return true if the event was successfully executed; false otherwise.
*/
- public abstract boolean process();
+
+ @Override
+ public String toString() {
+ return type + " ApplicationEvent";
+ }
+ public enum Type {
Review Comment:
this is used in the stub commit application event in the prototype.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
