[jira] [Commented] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17313259#comment-17313259 ] John Roesler commented on KAFKA-12593: -- Thanks for the confirmation, [~jmclean] !

[jira] [Updated] (KAFKA-12593) Some Scala, Python, and Gradle files contain the wrong license header

[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12593: - Summary: Some Scala, Python, and Gradle files contain the wrong license header (was: The Stream

[jira] [Created] (KAFKA-12602) The LICENSE and NOTICE files don't list everything they should

John Roesler created KAFKA-12602: Summary: The LICENSE and NOTICE files don't list everything they should Key: KAFKA-12602 URL: https://issues.apache.org/jira/browse/KAFKA-12602 Project: Kafka

[jira] [Commented] (KAFKA-12593) The Streams-Scala contains the wrong license header

[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312716#comment-17312716 ] John Roesler commented on KAFKA-12593: -- Thanks for the reminder, Sophie. I had forg

[jira] [Commented] (KAFKA-12593) The Streams-Scala contains the wrong license header

[ https://issues.apache.org/jira/browse/KAFKA-12593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312609#comment-17312609 ] John Roesler commented on KAFKA-12593: -- Hi [~jmclean] , I don't know if you will g

[jira] [Created] (KAFKA-12593) The Streams-Scala contains the wrong license header

John Roesler created KAFKA-12593: Summary: The Streams-Scala contains the wrong license header Key: KAFKA-12593 URL: https://issues.apache.org/jira/browse/KAFKA-12593 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-12557) org.apache.kafka.clients.admin.KafkaAdminClientTest#testClientSideTimeoutAfterFailureToReceiveResponse intermittently hangs indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-12557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-12557. -- Resolution: Fixed > org.apache.kafka.clients.admin.KafkaAdminClientTest#testClientSideTimeoutA

[jira] [Resolved] (KAFKA-12435) Several streams-test-utils classes missing from javadoc

[ https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-12435. -- Resolution: Fixed > Several streams-test-utils classes missing from javadoc >

[jira] [Comment Edited] (KAFKA-12360) Improve documentation of max.task.idle.ms (kafka-streams)

[ https://issues.apache.org/jira/browse/KAFKA-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309113#comment-17309113 ] John Roesler edited comment on KAFKA-12360 at 3/26/21, 2:57 AM: --

[jira] [Commented] (KAFKA-12360) Improve documentation of max.task.idle.ms (kafka-streams)

[ https://issues.apache.org/jira/browse/KAFKA-12360?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309113#comment-17309113 ] John Roesler commented on KAFKA-12360: -- Hi [~nicodds] , I can see your line of rea

[jira] [Resolved] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-12508. -- Resolution: Fixed Disabled KIP-557 entirely. > Emit-on-change tables may lose updates on erro

[jira] [Updated] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12508: - Affects Version/s: 2.6.0 > Emit-on-change tables may lose updates on error or restart in at_leas

[jira] [Created] (KAFKA-12557) org.apache.kafka.clients.admin.KafkaAdminClientTest#testClientSideTimeoutAfterFailureToReceiveResponse intermittently hangs indefinitely

John Roesler created KAFKA-12557: Summary: org.apache.kafka.clients.admin.KafkaAdminClientTest#testClientSideTimeoutAfterFailureToReceiveResponse intermittently hangs indefinitely Key: KAFKA-12557 URL: https://is

[jira] [Commented] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308063#comment-17308063 ] John Roesler commented on KAFKA-12508: -- Thanks [~cmaus] , I think you're right. Si

[jira] [Reopened] (KAFKA-12508) Emit-on-change tables may lose updates on error or restart in at_least_once

[ https://issues.apache.org/jira/browse/KAFKA-12508?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-12508: -- Assignee: John Roesler (was: Bruno Cadonna) > Emit-on-change tables may lose updates on err

[jira] [Commented] (KAFKA-12435) Several streams-test-utils classes missing from javadoc

[ https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17307511#comment-17307511 ] John Roesler commented on KAFKA-12435: -- Thanks for the report, [~ijuma] . The error

[jira] [Assigned] (KAFKA-12435) Several streams-test-utils classes missing from javadoc

[ https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-12435: Assignee: John Roesler > Several streams-test-utils classes missing from javadoc > --

[jira] [Updated] (KAFKA-12435) Several streams-test-utils classes missing from javadoc

[ https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12435: - Priority: Blocker (was: Major) > Several streams-test-utils classes missing from javadoc >

[jira] [Updated] (KAFKA-12435) Several streams-test-utils classes missing from javadoc

[ https://issues.apache.org/jira/browse/KAFKA-12435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12435: - Fix Version/s: 2.8.0 > Several streams-test-utils classes missing from javadoc > ---

[jira] [Updated] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12366: - Fix Version/s: (was: 3.0.0) > Performance regression in stream-table joins on trunk > --

[jira] [Resolved] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-12366. -- Resolution: Fixed > Performance regression in stream-table joins on trunk > --

[jira] [Updated] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12366: - Description: Stream-table join benchmarks have revealed a significant performance regression on

[jira] [Commented] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306708#comment-17306708 ] John Roesler commented on KAFKA-12366: -- Thanks for the report [~vcrfxia] , I have r

[jira] [Updated] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12366: - Fix Version/s: (was: 2.8.0) 3.0.0 > Performance regression in stream-tabl

[jira] [Assigned] (KAFKA-12366) Performance regression in stream-table joins on trunk

[ https://issues.apache.org/jira/browse/KAFKA-12366?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-12366: Assignee: John Roesler > Performance regression in stream-table joins on trunk >

[jira] [Commented] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306704#comment-17306704 ] John Roesler commented on KAFKA-10336: -- Well, here we are at 2.8 and still no fix.

[jira] [Updated] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10336: - Fix Version/s: (was: 3.0.0) > Rolling upgrade with Suppression may throw exceptions > --

[jira] [Updated] (KAFKA-10336) Rolling upgrade with Suppression may throw exceptions

[ https://issues.apache.org/jira/browse/KAFKA-10336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10336: - Fix Version/s: (was: 2.8.0) 3.0.0 > Rolling upgrade with Suppression may

[jira] [Commented] (KAFKA-12173) Migrate streams:streams-scala module to JUnit 5

[ https://issues.apache.org/jira/browse/KAFKA-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306702#comment-17306702 ] John Roesler commented on KAFKA-12173: -- Ah, bummer. I was sorry to find this PR wai

[jira] [Updated] (KAFKA-12173) Migrate streams:streams-scala module to JUnit 5

[ https://issues.apache.org/jira/browse/KAFKA-12173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12173: - Fix Version/s: (was: 2.8.0) 3.0.0 > Migrate streams:streams-scala module

[jira] [Commented] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306689#comment-17306689 ] John Roesler commented on KAFKA-10292: -- It looks like the PR didn't make the releas

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10292: - Fix Version/s: (was: 2.8.0) 3.0.0 > fix flaky streams/streams_broker_boun

[jira] [Commented] (KAFKA-9910) Implement new transaction timed out error

[ https://issues.apache.org/jira/browse/KAFKA-9910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306408#comment-17306408 ] John Roesler commented on KAFKA-9910: - Hey [~bchen225242] / [~zhaohaidao] , what's th

[jira] [Updated] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10233: - Fix Version/s: (was: 2.8.0) 3.0.0 > KafkaConsumer polls in a tight loop i

[jira] [Commented] (KAFKA-10233) KafkaConsumer polls in a tight loop if group is not authorized

[ https://issues.apache.org/jira/browse/KAFKA-10233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306407#comment-17306407 ] John Roesler commented on KAFKA-10233: -- This has been ongoing for quite a while. I'

[jira] [Commented] (KAFKA-9705) Zookeeper mutation protocols should be redirected to Controller only

[ https://issues.apache.org/jira/browse/KAFKA-9705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306403#comment-17306403 ] John Roesler commented on KAFKA-9705: - Hey [~bchen225242] , what is the status of thi

[jira] [Commented] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306399#comment-17306399 ] John Roesler commented on KAFKA-10201: -- This has been ongoing for quite a while. I'

[jira] [Commented] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306396#comment-17306396 ] John Roesler commented on KAFKA-9803: - This has been ongoing for quite a while. I'll

[jira] [Updated] (KAFKA-10201) Update codebase to use more inclusive terms

[ https://issues.apache.org/jira/browse/KAFKA-10201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10201: - Fix Version/s: (was: 2.8.0) 3.0.0 > Update codebase to use more inclusive

[jira] [Updated] (KAFKA-9803) Allow producers to recover gracefully from transaction timeouts

[ https://issues.apache.org/jira/browse/KAFKA-9803?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9803: Fix Version/s: (was: 2.8.0) 3.0.0 > Allow producers to recover gracefully fr

[jira] [Commented] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306394#comment-17306394 ] John Roesler commented on KAFKA-7493: - This has been ongoing for quite a while. I'll

[jira] [Updated] (KAFKA-7493) Rewrite test_broker_type_bounce_at_start

[ https://issues.apache.org/jira/browse/KAFKA-7493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7493: Fix Version/s: (was: 2.8.0) 3.0.0 > Rewrite test_broker_type_bounce_at_start

[jira] [Commented] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306392#comment-17306392 ] John Roesler commented on KAFKA-10642: -- Hi [~senthilm-ms] , it looks like this has

[jira] [Updated] (KAFKA-10642) Expose the real stack trace if any exception occurred during SSL Client Trust Verification in extension

[ https://issues.apache.org/jira/browse/KAFKA-10642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10642: - Fix Version/s: (was: 2.8.0) 3.0.0 > Expose the real stack trace if any ex

[jira] [Updated] (KAFKA-10641) ACL Command hangs with SSL as not existing with proper error code

[ https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10641: - Fix Version/s: (was: 2.8.0) 3.0.0 > ACL Command hangs with SSL as not exi

[jira] [Commented] (KAFKA-10641) ACL Command hangs with SSL as not existing with proper error code

[ https://issues.apache.org/jira/browse/KAFKA-10641?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306389#comment-17306389 ] John Roesler commented on KAFKA-10641: -- Hi [~senthilm-ms] , it looks like this has

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9861: Affects Version/s: (was: 2.5.1) (was: 2.4.2)

[jira] [Commented] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306373#comment-17306373 ] John Roesler commented on KAFKA-9861: - Hi, [~iekpo] , I hope you've been well. Sinc

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9861: Fix Version/s: (was: 2.5.2) (was: 2.4.2) (was: 3.0

[jira] [Updated] (KAFKA-9861) Process Simplification - Community Validation of Kafka Release Candidates

[ https://issues.apache.org/jira/browse/KAFKA-9861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9861: Fix Version/s: (was: 2.8.0) 3.0.0 > Process Simplification - Community Valid

[jira] [Commented] (KAFKA-7025) Android client support

[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306372#comment-17306372 ] John Roesler commented on KAFKA-7025: - I bumped the fix version to 3.0, since this is

[jira] [Updated] (KAFKA-7025) Android client support

[ https://issues.apache.org/jira/browse/KAFKA-7025?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7025: Fix Version/s: (was: 2.8.0) 3.0.0 > Android client support > ---

[jira] [Updated] (KAFKA-10343) Add IBP based ApiVersion constraint tests

[ https://issues.apache.org/jira/browse/KAFKA-10343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10343: - Fix Version/s: (was: 2.8.0) > Add IBP based ApiVersion constraint tests > --

[jira] [Commented] (KAFKA-10749) Add throttling of IPs by connection rate

[ https://issues.apache.org/jira/browse/KAFKA-10749?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306360#comment-17306360 ] John Roesler commented on KAFKA-10749: -- Hey, [~david.mao] , is this work complete?

[jira] [Commented] (KAFKA-12295) Shallow Mirroring

[ https://issues.apache.org/jira/browse/KAFKA-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17306357#comment-17306357 ] John Roesler commented on KAFKA-12295: -- Hey, [~h...@pinterest.com] , I've removed t

[jira] [Updated] (KAFKA-12295) Shallow Mirroring

[ https://issues.apache.org/jira/browse/KAFKA-12295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12295: - Fix Version/s: (was: 2.8.0) > Shallow Mirroring > - > > Key:

[jira] [Created] (KAFKA-12514) NPE in SubscriptionState

John Roesler created KAFKA-12514: Summary: NPE in SubscriptionState Key: KAFKA-12514 URL: https://issues.apache.org/jira/browse/KAFKA-12514 Project: Kafka Issue Type: Bug Components

[jira] [Updated] (KAFKA-12462) Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal state exception

[ https://issues.apache.org/jira/browse/KAFKA-12462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12462: - Fix Version/s: 2.8.0 > Threads in PENDING_SHUTDOWN entering a rebalance can cause an illegal sta

[jira] [Updated] (KAFKA-12254) MirrorMaker 2.0 creates destination topic with default configs

[ https://issues.apache.org/jira/browse/KAFKA-12254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12254: - Fix Version/s: 2.8.0 > MirrorMaker 2.0 creates destination topic with default configs >

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291734#comment-17291734 ] John Roesler commented on KAFKA-12375: -- Thanks [~ableegoldman] . I couldn't believ

[jira] [Commented] (KAFKA-10619) Producer will enable EOS by default

[ https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291284#comment-17291284 ] John Roesler commented on KAFKA-10619: -- Hey [~d8tltanc] , I noticed in your PR that

[jira] [Updated] (KAFKA-10619) Producer will enable EOS by default

[ https://issues.apache.org/jira/browse/KAFKA-10619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10619: - Description: This is an after-work for KIP-185.  In the producer config, # the default value o

[jira] [Commented] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17291209#comment-17291209 ] John Roesler commented on KAFKA-12375: -- Thanks, all. The 2.8 branch is not yet stab

[jira] [Updated] (KAFKA-12375) ReplaceStreamThread creates a new consumer with the same name as the one it's replacing

[ https://issues.apache.org/jira/browse/KAFKA-12375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-12375: - Priority: Blocker (was: Major) > ReplaceStreamThread creates a new consumer with the same name

[jira] [Commented] (KAFKA-12242) Decouple state store materialization enforcement from name/serde provider

[ https://issues.apache.org/jira/browse/KAFKA-12242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288646#comment-17288646 ] John Roesler commented on KAFKA-12242: -- Thanks for raising this, [~guozhang] , I ha

[jira] [Resolved] (KAFKA-10866) Add fetched metadata to ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-10866. -- Resolution: Fixed > Add fetched metadata to ConsumerRecords >

[jira] [Updated] (KAFKA-10866) Add fetched metadata to ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10866: - Priority: Major (was: Blocker) > Add fetched metadata to ConsumerRecords >

[jira] [Updated] (KAFKA-10866) Add fetched metadata to ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10866: - Priority: Blocker (was: Major) > Add fetched metadata to ConsumerRecords >

[jira] [Reopened] (KAFKA-10866) Add fetched metadata to ConsumerRecords

[ https://issues.apache.org/jira/browse/KAFKA-10866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-10866: -- > Add fetched metadata to ConsumerRecords > --- > >

[jira] [Reopened] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-10091: -- > Improve task idling > --- > > Key: KAFKA-10091 >

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17277249#comment-17277249 ] John Roesler commented on KAFKA-10091: -- Reopened, since I still need to update the

[jira] [Commented] (KAFKA-12185) Flaky Test StoreQueryIntegrationTest#shouldQueryAllStalePartitionStores

[ https://issues.apache.org/jira/browse/KAFKA-12185?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17268805#comment-17268805 ] John Roesler commented on KAFKA-12185: -- I just saw this fail locally and happened t

[jira] [Updated] (KAFKA-10851) Add Cluster Describe API

[ https://issues.apache.org/jira/browse/KAFKA-10851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10851: - Component/s: core > Add Cluster Describe API > > > Key:

[jira] [Updated] (KAFKA-10810) Add a replace thread option to the streams uncaught exception handler

[ https://issues.apache.org/jira/browse/KAFKA-10810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10810: - Fix Version/s: 2.8.0 > Add a replace thread option to the streams uncaught exception handler >

[jira] [Commented] (KAFKA-9566) ProcessorContextImpl#forward throws NullPointerException if invoked from DeserializationExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-9566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17259416#comment-17259416 ] John Roesler commented on KAFKA-9566: - Hi all, Thanks, [~mjsax] , that's a good thou

[jira] [Comment Edited] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244326#comment-17244326 ] John Roesler edited comment on KAFKA-10091 at 1/4/21, 7:51 PM: ---

[jira] [Created] (KAFKA-10867) Implement improved semantics using the ConsumerRecords meta

John Roesler created KAFKA-10867: Summary: Implement improved semantics using the ConsumerRecords meta Key: KAFKA-10867 URL: https://issues.apache.org/jira/browse/KAFKA-10867 Project: Kafka

[jira] [Created] (KAFKA-10866) Add fetched metadata to ConsumerRecords

John Roesler created KAFKA-10866: Summary: Add fetched metadata to ConsumerRecords Key: KAFKA-10866 URL: https://issues.apache.org/jira/browse/KAFKA-10866 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17246741#comment-17246741 ] John Roesler commented on KAFKA-10772: -- Thanks, [~cadonna] ! The scenario you outl

[jira] [Updated] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10772: - Fix Version/s: 2.7.0 > java.lang.IllegalStateException: There are insufficient bytes available t

[jira] [Updated] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10772: - Priority: Blocker (was: Major) > java.lang.IllegalStateException: There are insufficient bytes

[jira] [Commented] (KAFKA-10772) java.lang.IllegalStateException: There are insufficient bytes available to read assignment from the sync-group response (actual byte size 0)

[ https://issues.apache.org/jira/browse/KAFKA-10772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17245456#comment-17245456 ] John Roesler commented on KAFKA-10772: -- Hey [~bbejeck] , this might be a bit aggres

[jira] [Assigned] (KAFKA-7458) Avoid enforced processing during bootstrap phase

[ https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7458: --- Assignee: John Roesler (was: Guozhang Wang) > Avoid enforced processing during bootstrap ph

[jira] [Assigned] (KAFKA-8478) Poll for more records before forced processing

[ https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8478: --- Assignee: John Roesler > Poll for more records before forced processing > --

[jira] [Commented] (KAFKA-8315) Historical join issues

[ https://issues.apache.org/jira/browse/KAFKA-8315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244330#comment-17244330 ] John Roesler commented on KAFKA-8315: - Hello, all, I have just proposed KIP-695, whic

[jira] [Commented] (KAFKA-8478) Poll for more records before forced processing

[ https://issues.apache.org/jira/browse/KAFKA-8478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244329#comment-17244329 ] John Roesler commented on KAFKA-8478: - Hello, all, I have just proposed KIP-695, whic

[jira] [Commented] (KAFKA-7458) Avoid enforced processing during bootstrap phase

[ https://issues.apache.org/jira/browse/KAFKA-7458?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244327#comment-17244327 ] John Roesler commented on KAFKA-7458: - Hello, all, I have just proposed KIP-695, whic

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244326#comment-17244326 ] John Roesler commented on KAFKA-10091: -- Hello, all! I have just started the discuss

[jira] [Commented] (KAFKA-2967) Move Kafka documentation to ReStructuredText

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17244180#comment-17244180 ] John Roesler commented on KAFKA-2967: - I just took a look at [~tombentley]'s proposal

[jira] [Commented] (KAFKA-2967) Move Kafka documentation to ReStructuredText

[ https://issues.apache.org/jira/browse/KAFKA-2967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17243503#comment-17243503 ] John Roesler commented on KAFKA-2967: - Hi [~JimGalasyn] , Thanks for that informatio

[jira] [Commented] (KAFKA-10417) suppress() with cogroup() throws ClassCastException

[ https://issues.apache.org/jira/browse/KAFKA-10417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17242806#comment-17242806 ] John Roesler commented on KAFKA-10417: -- Hey [~duvholt] , I'm really sorry I missed

[jira] [Closed] (KAFKA-10758) Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a new topic

[ https://issues.apache.org/jira/browse/KAFKA-10758?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-10758. > Kafka Streams consuming from a pattern goes to PENDING_SHUTDOWN when adding a > new topic > ---

[jira] [Closed] (KAFKA-10754) Fix flaky shouldShutdownSingleThreadApplication test

[ https://issues.apache.org/jira/browse/KAFKA-10754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler closed KAFKA-10754. > Fix flaky shouldShutdownSingleThreadApplication test > -

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10292: - Priority: Blocker (was: Major) > fix flaky streams/streams_broker_bounce_test.py >

[jira] [Updated] (KAFKA-10292) fix flaky streams/streams_broker_bounce_test.py

[ https://issues.apache.org/jira/browse/KAFKA-10292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10292: - Fix Version/s: 2.8.0 > fix flaky streams/streams_broker_bounce_test.py > ---

[jira] [Updated] (KAFKA-10017) Flaky Test EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta

[ https://issues.apache.org/jira/browse/KAFKA-10017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10017: - Fix Version/s: (was: 2.6.0) 2.8.0 > Flaky Test EosBetaUpgradeIntegrationT

[jira] [Commented] (KAFKA-10091) Improve task idling

[ https://issues.apache.org/jira/browse/KAFKA-10091?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17234967#comment-17234967 ] John Roesler commented on KAFKA-10091: -- FYI to all watchers, I've begun to draft a

[jira] [Commented] (KAFKA-10604) The StreamsConfig.STATE_DIR_CONFIG's default value does not reflect the JVM parameter or OS-specific settings

[ https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17227150#comment-17227150 ] John Roesler commented on KAFKA-10604: -- I agree; I do not think this needs a KIP. I

[jira] [Updated] (KAFKA-10604) The StreamsConfig.STATE_DIR_CONFIG's default value does not reflect the JVM parameter or OS-specific settings

[ https://issues.apache.org/jira/browse/KAFKA-10604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-10604: - Issue Type: Bug (was: Improvement) > The StreamsConfig.STATE_DIR_CONFIG's default value does no

[jira] [Commented] (KAFKA-10515) NPE: Foreign key join serde may not be initialized with default serde if application is distributed

[ https://issues.apache.org/jira/browse/KAFKA-10515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17225532#comment-17225532 ] John Roesler commented on KAFKA-10515: -- [https://github.com/apache/kafka/pull/9467]

<    1   2   3   4   5   6   7   8   9   10   >