[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1288175911 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -86,12 +87,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1288175911 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -86,12 +87,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1287335415 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -86,12 +87,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1286114522 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -86,12 +87,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1286114522 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -86,12 +87,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1286049066 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -87,11 +88,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1286048632 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -87,11 +88,29 @@ private void runOnce(final long nowMs) {

[GitHub] [kafka] lucasbru commented on a diff in pull request #14001: Kafka Streams Threading: Punctuation (5/N)

lucasbru commented on code in PR #14001: URL: https://github.com/apache/kafka/pull/14001#discussion_r1286048380 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/tasks/DefaultTaskExecutor.java: ## @@ -87,11 +88,29 @@ private void runOnce(final long nowMs) {