[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1115068319 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1115056524 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1114928370 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1114930390 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1114928370 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1114851962 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1109286591 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1109283896 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEvent.java: ## @@ -19,23 +19,35 @@ /** * This is the abstract definition of

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1109264154 ## clients/src/main/java/org/apache/kafka/clients/consumer/StubbedAsyncKafkaConsumer.java: ## @@ -0,0 +1,548 @@ +/* + * Licensed to the Apache Software Foundation (AS

[GitHub] [kafka] philipnee commented on a diff in pull request #13265: Prototype consumer stubs

philipnee commented on code in PR #13265: URL: https://github.com/apache/kafka/pull/13265#discussion_r1109260958 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/CompletableApplicationEvent.java: ## @@ -0,0 +1,57 @@ +/* + * Licensed to the Apache Softw