[jira] [Assigned] (KAFKA-8147) Add changelog topic configuration to KTable suppress

[ https://issues.apache.org/jira/browse/KAFKA-8147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8147: --- Assignee: (was: Maarten) > Add changelog topic configuration to KTable suppress > --

[jira] [Resolved] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9310. - Resolution: Fixed > StreamThread may die from recoverable UnknownProducerId exception > -

[jira] [Updated] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9310: Fix Version/s: 2.4.1 > StreamThread may die from recoverable UnknownProducerId exception >

[jira] [Assigned] (KAFKA-7943) Add Suppress system test with caching disabled.

[ https://issues.apache.org/jira/browse/KAFKA-7943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7943: --- Assignee: (was: John Roesler) > Add Suppress system test with caching disabled. > --

[jira] [Assigned] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

[ https://issues.apache.org/jira/browse/KAFKA-9310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9310: --- Assignee: John Roesler > StreamThread may die from recoverable UnknownProducerId exception >

[jira] [Created] (KAFKA-9310) StreamThread may die from recoverable UnknownProducerId exception

John Roesler created KAFKA-9310: --- Summary: StreamThread may die from recoverable UnknownProducerId exception Key: KAFKA-9310 URL: https://issues.apache.org/jira/browse/KAFKA-9310 Project: Kafka

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997447#comment-16997447 ] John Roesler commented on KAFKA-9259: - Hi [~omanges], yes, of course! Although this

[jira] [Commented] (KAFKA-9302) Allow custom partitioning in foreign-key joins

[ https://issues.apache.org/jira/browse/KAFKA-9302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997432#comment-16997432 ] John Roesler commented on KAFKA-9302: - Thanks for the report, [~mjsax]. It also comes

[jira] [Resolved] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

[ https://issues.apache.org/jira/browse/KAFKA-9138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9138. - Resolution: Fixed Added the system test in https://github.com/apache/kafka/commit/717ce42a6d68d3

[jira] [Commented] (KAFKA-6078) Investigate failure of ReassignPartitionsClusterTest.shouldExpandCluster

[ https://issues.apache.org/jira/browse/KAFKA-6078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993754#comment-16993754 ] John Roesler commented on KAFKA-6078: - This had just failed for me on https://builds

[jira] [Commented] (KAFKA-9289) consolidate all the streams smoke system tests

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

[jira] [Updated] (KAFKA-9289) consolidate all the streams smoke system tests

[ https://issues.apache.org/jira/browse/KAFKA-9289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9289: Labels: system-tests (was: ) > consolidate all the streams smoke system tests > --

[jira] [Created] (KAFKA-9289) consolidate all the streams smoke system tests

John Roesler created KAFKA-9289: --- Summary: consolidate all the streams smoke system tests Key: KAFKA-9289 URL: https://issues.apache.org/jira/browse/KAFKA-9289 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-9234) Consider using @Nullable and @Nonnull annotations

[ https://issues.apache.org/jira/browse/KAFKA-9234?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990681#comment-16990681 ] John Roesler commented on KAFKA-9234: - Hi [~hmed06], The answer is yes, you can just

[jira] [Commented] (KAFKA-9034) kafka-run-class.sh will fail if JAVA_HOME has space

[ https://issues.apache.org/jira/browse/KAFKA-9034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990678#comment-16990678 ] John Roesler commented on KAFKA-9034: - Either way, it would be a best practice to quo

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990553#comment-16990553 ] John Roesler commented on KAFKA-9275: - Yeah, to be honest, I was a little concerned a

[jira] [Commented] (KAFKA-9275) Print assignment and IP address in the log message when consumer leaves/removed from the group

[ https://issues.apache.org/jira/browse/KAFKA-9275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16990311#comment-16990311 ] John Roesler commented on KAFKA-9275: - Hi [~dengziming], It looks like you should be

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989980#comment-16989980 ] John Roesler commented on KAFKA-9274: - Yep, something like that is what I would propo

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989968#comment-16989968 ] John Roesler commented on KAFKA-9270: - Hi [~rohan26may], No problem. I was actually

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989401#comment-16989401 ] John Roesler commented on KAFKA-9270: - Hey Rohan, I see where you’re coming from, bu

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989225#comment-16989225 ] John Roesler commented on KAFKA-9225: - I see what you did there :) Forking RocksDB i

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989201#comment-16989201 ] John Roesler commented on KAFKA-9225: - Hey [~guozhang], Yes, I think it would be ok

[jira] [Comment Edited] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989195#comment-16989195 ] John Roesler edited comment on KAFKA-9274 at 12/5/19 9:47 PM: -

[jira] [Commented] (KAFKA-9274) Gracefully handle timeout exceptions on Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-9274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989195#comment-16989195 ] John Roesler commented on KAFKA-9274: - Thanks for starting this, [~bchen225242]! One

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16989123#comment-16989123 ] John Roesler commented on KAFKA-9270: - Agreed, [~bchen225242], and I'm actually on bo

[jira] [Commented] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988953#comment-16988953 ] John Roesler commented on KAFKA-9268: - The only compatibility concern I'm aware of is

[jira] [Commented] (KAFKA-9270) KafkaStream crash on offset commit failure

[ https://issues.apache.org/jira/browse/KAFKA-9270?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988923#comment-16988923 ] John Roesler commented on KAFKA-9270: - Hey Rohan, There is a Consumer config to cont

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988913#comment-16988913 ] John Roesler commented on KAFKA-9088: - Thanks, Bruno, I don’t want you to feel besieg

[jira] [Commented] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987992#comment-16987992 ] John Roesler commented on KAFKA-9231: - Opened https://issues.apache.org/jira/browse/K

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Description: While testing Streams in EOS mode under frequent and heavy network partitions, I've e

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Attachment: 2.2-eos-failures-1.txt 2.2-eos-failures-2.txt > Follow-on: Streams Thre

[jira] [Assigned] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9268: --- Assignee: (was: John Roesler) > Follow-on: Streams Threads may die from recoverable erro

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Description: While testing Streams in EOS mode under frequent and heavy network partitions, I've e

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Affects Version/s: (was: 2.4.0) 2.2.0 > Follow-on: Streams Threads may d

[jira] [Updated] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9268?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9268: Priority: Major (was: Blocker) > Follow-on: Streams Threads may die from recoverable errors with E

[jira] [Created] (KAFKA-9268) Follow-on: Streams Threads may die from recoverable errors with EOS enabled

John Roesler created KAFKA-9268: --- Summary: Follow-on: Streams Threads may die from recoverable errors with EOS enabled Key: KAFKA-9268 URL: https://issues.apache.org/jira/browse/KAFKA-9268 Project: Kafk

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987985#comment-16987985 ] John Roesler commented on KAFKA-9088: - Thanks for the justification, [~cadonna]. Sinc

[jira] [Commented] (KAFKA-9225) kafka fail to run on linux-aarch64

[ https://issues.apache.org/jira/browse/KAFKA-9225?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987953#comment-16987953 ] John Roesler commented on KAFKA-9225: - When we discussed this before, we didn’t have

[jira] [Commented] (KAFKA-9088) Consolidate InternalMockProcessorContext and MockInternalProcessorContext

[ https://issues.apache.org/jira/browse/KAFKA-9088?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987478#comment-16987478 ] John Roesler commented on KAFKA-9088: - Hey all, I can see I've missed some discussio

[jira] [Comment Edited] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987395#comment-16987395 ] John Roesler edited comment on KAFKA-9231 at 12/4/19 1:14 AM: -

[jira] [Resolved] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9231. - Resolution: Fixed Fixed in 2.4 by https://github.com/apache/kafka/commit/d7fe494b2a983256092bcc5

[jira] [Commented] (KAFKA-6718) Rack Aware Stand-by Task Assignment for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-6718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16987281#comment-16987281 ] John Roesler commented on KAFKA-6718: - Hey [~lkokhreidze]. I know Matthias pinged me

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Affects Version/s: 2.4.0 > Reocurrence: Transient failure in > kafka.api.AdminClientIntegrationTes

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Fix Version/s: (was: 1.1.0) > Reocurrence: Transient failure in > kafka.api.AdminClientIntegra

[jira] [Updated] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9264: Reporter: John Roesler (was: Matthias J. Sax) > Reocurrence: Flaky Test > DelegationTokenEndToEnd

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Description: This test has failed for me on https://builds.apache.org/job/kafka-pr-jdk11-scala2.12

[jira] [Assigned] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9263: --- Assignee: (was: Dong Lin) > Reocurrence: Transient failure in > kafka.api.AdminClientIn

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Reporter: John Roesler (was: Guozhang Wang) > Reocurrence: Transient failure in > kafka.api.Admin

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Component/s: (was: unit tests) clients > Reocurrence: Transient failure in >

[jira] [Created] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

John Roesler created KAFKA-9263: --- Summary: Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs Key: KAFKA-9263

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Labels: flaky-test (was: ) > Reocurrence: Transient failure in > kafka.api.AdminClientIntegration

[jira] [Updated] (KAFKA-9263) Reocurrence: Transient failure in kafka.api.AdminClientIntegrationTest.testLogStartOffsetCheckpointkafka.api.AdminClientIntegrationTest.testAlterReplicaLogDirs

[ https://issues.apache.org/jira/browse/KAFKA-9263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9263: Description: This test has failed for me on https://builds.apache.org/job/kafka-pr-jdk11-scala2.12

[jira] [Updated] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-9264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9264: Description: This test has failed again for me, so apparently it's not fixed: https://builds.apache

[jira] [Created] (KAFKA-9264) Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

John Roesler created KAFKA-9264: --- Summary: Reocurrence: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9264 URL: https://issues.apache.org/jira/b

[jira] [Reopened] (KAFKA-8937) Flaky Test SaslPlainSslEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

[ https://issues.apache.org/jira/browse/KAFKA-8937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reopened KAFKA-8937: - This test has just failed again for me. Apparently, it is not fixed. Unfortunately, Jenkins didn't c

[jira] [Commented] (KAFKA-9259) suppress() for windowed-Serdes does not work with default serdes

[ https://issues.apache.org/jira/browse/KAFKA-9259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16986546#comment-16986546 ] John Roesler commented on KAFKA-9259: - Thanks for the report, [~mjsax]! Just a quick

[jira] [Comment Edited] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985429#comment-16985429 ] John Roesler edited comment on KAFKA-9231 at 11/30/19 8:32 PM:

[jira] [Updated] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9231: Priority: Blocker (was: Major) > Streams Threads may die from recoverable errors with EOS enabled

[jira] [Commented] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16985429#comment-16985429 ] John Roesler commented on KAFKA-9231: - In addition to the error I listed above (Produ

[jira] [Updated] (KAFKA-9231) Streams Threads may die from recoverable errors with EOS enabled

[ https://issues.apache.org/jira/browse/KAFKA-9231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9231: Summary: Streams Threads may die from recoverable errors with EOS enabled (was: ProducerFencedExce

[jira] [Commented] (KAFKA-8769) Consider computing stream time independently per key

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16983091#comment-16983091 ] John Roesler commented on KAFKA-8769: - Yes, that is a problem. It’s why I mentioned t

[jira] [Created] (KAFKA-9231) ProducerFencedException may cause Streams Thread to die

John Roesler created KAFKA-9231: --- Summary: ProducerFencedException may cause Streams Thread to die Key: KAFKA-9231 URL: https://issues.apache.org/jira/browse/KAFKA-9231 Project: Kafka Issue Typ

[jira] [Commented] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16981693#comment-16981693 ] John Roesler commented on KAFKA-7663: - Hey, all, I just became aware of this ticket

[jira] [Updated] (KAFKA-7663) Custom Processor supplied on addGlobalStore is not used when restoring state from topic

[ https://issues.apache.org/jira/browse/KAFKA-7663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7663: Issue Type: Improvement (was: Bug) > Custom Processor supplied on addGlobalStore is not used when

[jira] [Commented] (KAFKA-7940) Flaky Test CustomQuotaCallbackTest#testCustomQuotaCallback

[ https://issues.apache.org/jira/browse/KAFKA-7940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16980512#comment-16980512 ] John Roesler commented on KAFKA-7940: - Failed again in https://github.com/apache/kafk

[jira] [Commented] (KAFKA-9222) StreamPartitioner for internal repartition topics does not match defaults for to() operation

[ https://issues.apache.org/jira/browse/KAFKA-9222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16979700#comment-16979700 ] John Roesler commented on KAFKA-9222: - Thanks for the report! It does sound like a b

[jira] [Commented] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16975723#comment-16975723 ] John Roesler commented on KAFKA-9169: - Thanks, Navinder. I’ve set the affected versio

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Affects Version/s: (was: 2.3.0) 1.1.0 > Standby Tasks point ask for inco

[jira] [Commented] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16974430#comment-16974430 ] John Roesler commented on KAFKA-9169: - Aha, that makes more sense... Thanks, [~mjsax]

[jira] [Resolved] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9169. - Resolution: Fixed This was fixed in https://github.com/apache/kafka/pull/7681/ and merged to tru

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Fix Version/s: 2.5.0 > Standby Tasks point ask for incorrect offsets on resuming post suspension >

[jira] [Commented] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16972911#comment-16972911 ] John Roesler commented on KAFKA-9169: - After testing, I've determined that the bug is

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Affects Version/s: 2.3.2 2.3.1 2.3.0 > Standby Tasks

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Priority: Critical (was: Blocker) > Standby Tasks point ask for incorrect offsets on resuming post

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Priority: Blocker (was: Critical) > Standby Tasks point ask for incorrect offsets on resuming post

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Affects Version/s: 2.4.0 > Standby Tasks point ask for incorrect offsets on resuming post suspensio

[jira] [Updated] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9169: Issue Type: Bug (was: New Feature) > Standby Tasks point ask for incorrect offsets on resuming pos

[jira] [Assigned] (KAFKA-9169) Standby Tasks point ask for incorrect offsets on resuming post suspension

[ https://issues.apache.org/jira/browse/KAFKA-9169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9169: --- Assignee: John Roesler > Standby Tasks point ask for incorrect offsets on resuming post susp

[jira] [Commented] (KAFKA-9134) Refactor the StreamsPartitionAssignor for more code sharing with the FutureStreamsPartitionAssignor

[ https://issues.apache.org/jira/browse/KAFKA-9134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16969829#comment-16969829 ] John Roesler commented on KAFKA-9134: - Thanks for calling this out [~ableegoldman].

[jira] [Assigned] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7895: --- Assignee: John Roesler (was: Guozhang Wang) > Ktable supress operator emitting more than on

[jira] [Assigned] (KAFKA-7895) Ktable supress operator emitting more than one record for the same key per window

[ https://issues.apache.org/jira/browse/KAFKA-7895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-7895: --- Assignee: Guozhang Wang (was: John Roesler) > Ktable supress operator emitting more than on

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968534#comment-16968534 ] John Roesler commented on KAFKA-9148: - Thanks for the additional detail. I had one o

[jira] [Commented] (KAFKA-9148) Consider forking RocksDB for Streams

[ https://issues.apache.org/jira/browse/KAFKA-9148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16968097#comment-16968097 ] John Roesler commented on KAFKA-9148: - Thanks for bringing this up, Sophie. It does

[jira] [Created] (KAFKA-9138) Add system test covering Foreign Key joins (KIP-213)

John Roesler created KAFKA-9138: --- Summary: Add system test covering Foreign Key joins (KIP-213) Key: KAFKA-9138 URL: https://issues.apache.org/jira/browse/KAFKA-9138 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-9103) KIP-441: Add TaskLags to SubscriptionInfo

John Roesler created KAFKA-9103: --- Summary: KIP-441: Add TaskLags to SubscriptionInfo Key: KAFKA-9103 URL: https://issues.apache.org/jira/browse/KAFKA-9103 Project: Kafka Issue Type: Improvement

[jira] [Assigned] (KAFKA-8410) Strengthen the types of Processors, at least in the DSL, maybe in the PAPI as well

[ https://issues.apache.org/jira/browse/KAFKA-8410?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-8410: --- Assignee: John Roesler > Strengthen the types of Processors, at least in the DSL, maybe in t

[jira] [Comment Edited] (KAFKA-8882) It's not possible to restart Kafka Streams using StateListener

[ https://issues.apache.org/jira/browse/KAFKA-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954815#comment-16954815 ] John Roesler edited comment on KAFKA-8882 at 10/18/19 5:03 PM:

[jira] [Commented] (KAFKA-8882) It's not possible to restart Kafka Streams using StateListener

[ https://issues.apache.org/jira/browse/KAFKA-8882?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16954815#comment-16954815 ] John Roesler commented on KAFKA-8882: - Hey [~cjub], Sorry I didn't reply! It seems

[jira] [Resolved] (KAFKA-8902) Benchmark cooperative vs eager rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-8902. - Resolution: Fixed I wrote a simple Streams application using the Processor API to update 10 stor

[jira] [Created] (KAFKA-9058) Foreign Key Join should not require a queriable store

John Roesler created KAFKA-9058: --- Summary: Foreign Key Join should not require a queriable store Key: KAFKA-9058 URL: https://issues.apache.org/jira/browse/KAFKA-9058 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952184#comment-16952184 ] John Roesler commented on KAFKA-9022: - It isn't a true duplicate, but both flaky test

[jira] [Resolved] (KAFKA-9022) Flaky Test KTableKTableForeignKeyJoinIntegrationTest. doInnerJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9022. - Resolution: Duplicate > Flaky Test KTableKTableForeignKeyJoinIntegrationTest. > doInnerJoinFilte

[jira] [Commented] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951519#comment-16951519 ] John Roesler commented on KAFKA-9032: - I'll pick this one up. I've reproduced the is

[jira] [Updated] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9000: Priority: Blocker (was: Major) > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeftJoi

[jira] [Updated] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-9000: Affects Version/s: 2.4.0 > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRi

[jira] [Assigned] (KAFKA-9032) Serializer is invoked with null when foreignValue=null

[ https://issues.apache.org/jira/browse/KAFKA-9032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9032: --- Assignee: John Roesler > Serializer is invoked with null when foreignValue=null > --

[jira] [Commented] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951517#comment-16951517 ] John Roesler commented on KAFKA-9006: - It isn't a true duplicate, but both flaky test

[jira] [Resolved] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler resolved KAFKA-9006. - Resolution: Duplicate > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterO

[jira] [Assigned] (KAFKA-9000) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFromRightThenDeleteRightEntity

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9000: --- Assignee: John Roesler > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinF

[jira] [Assigned] (KAFKA-9006) Flaky Test KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinFilterOutRapidlyChangingForeignKeyValues

[ https://issues.apache.org/jira/browse/KAFKA-9006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler reassigned KAFKA-9006: --- Assignee: John Roesler > Flaky Test > KTableKTableForeignKeyJoinIntegrationTest.doLeftJoinF

<    4   5   6   7   8   9   10   11   12   13   >