[jira] [Comment Edited] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784126#comment-16784126 ] leibo edited comment on KAFKA-5998 at 3/5/19 6:57 AM: -- It seems that {color:#ff}

[jira] [Created] (KAFKA-8041) Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll

Matthias J. Sax created KAFKA-8041: -- Summary: Flaky Test LogDirFailureTest#testIOExceptionDuringLogRoll Key: KAFKA-8041 URL: https://issues.apache.org/jira/browse/KAFKA-8041 Project: Kafka

[jira] [Commented] (KAFKA-7937) Flaky Test ResetConsumerGroupOffsetTest.testResetOffsetsNotExistingGroup

[ https://issues.apache.org/jira/browse/KAFKA-7937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784136#comment-16784136 ] Matthias J. Sax commented on KAFKA-7937: Again:

[jira] [Commented] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784131#comment-16784131 ] Matthias J. Sax commented on KAFKA-8026: Seems to fail consistently in `1.1`

[jira] [Assigned] (KAFKA-8026) Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAWhenDeleted

[ https://issues.apache.org/jira/browse/KAFKA-8026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8026: -- Assignee: Bill Bejeck > Flaky Test

[jira] [Commented] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784126#comment-16784126 ] leibo commented on KAFKA-5998: -- It seems that {color:#FF} final File temp = new

[jira] [Issue Comment Deleted] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu updated KAFKA-3729: -- Comment: was deleted (was: Joined class was added Sep 6 10:55:43 2017 Guozhang's comment above was made in

[jira] [Assigned] (KAFKA-7502) Cleanup KTable materialization logic in a single place

[ https://issues.apache.org/jira/browse/KAFKA-7502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-7502: -- Assignee: Lee Dongjin > Cleanup KTable materialization logic in a single place >

[jira] [Commented] (KAFKA-7996) KafkaStreams does not pass timeout when closing Producer

[ https://issues.apache.org/jira/browse/KAFKA-7996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784092#comment-16784092 ] Matthias J. Sax commented on KAFKA-7996: [~dongjin] Consumer also has config

[jira] [Commented] (KAFKA-7967) Kafka Streams: some values in statestore rollback to old value

[ https://issues.apache.org/jira/browse/KAFKA-7967?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784080#comment-16784080 ] Ziming Dong commented on KAFKA-7967: we created a replica statestore and found inconsistence between

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784075#comment-16784075 ] Matthias J. Sax commented on KAFKA-3729: The scope did no change. The "problem" is the following:

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16784019#comment-16784019 ] Ted Yu commented on KAFKA-3729: --- Joined class was added Sep 6 10:55:43 2017 Guozhang's comment above was

[jira] [Commented] (KAFKA-8040) Streams needs to retry initTransactions

[ https://issues.apache.org/jira/browse/KAFKA-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783999#comment-16783999 ] ASF GitHub Bot commented on KAFKA-8040: --- vvcephei commented on pull request #6372: KAFKA-8040:

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-7932: Description: Following on KAFKA-7763, Streams needs to handle the new behavior. See also 

[jira] [Updated] (KAFKA-8040) Streams needs to retry initTransactions

[ https://issues.apache.org/jira/browse/KAFKA-8040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Roesler updated KAFKA-8040: Description: Following on KAFKA-6446, Streams needs to handle the new behavior. `initTxn` can

[jira] [Commented] (KAFKA-7932) Streams needs to handle new Producer exceptions

[ https://issues.apache.org/jira/browse/KAFKA-7932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783940#comment-16783940 ] John Roesler commented on KAFKA-7932: - Thank you, [~mjsax]. That's a good suggestion. I've created

[jira] [Updated] (KAFKA-7932) Streams needs to handle new Producer exceptions

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

[jira] [Created] (KAFKA-8040) Streams needs to retry initTransactions

John Roesler created KAFKA-8040: --- Summary: Streams needs to retry initTransactions Key: KAFKA-8040 URL: https://issues.apache.org/jira/browse/KAFKA-8040 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-7747) Consumer should check for truncation after leader changes

[ https://issues.apache.org/jira/browse/KAFKA-7747?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783930#comment-16783930 ] ASF GitHub Bot commented on KAFKA-7747: --- mumrah commented on pull request #6371: KAFKA-7747 Check

[jira] [Commented] (KAFKA-7880) KafkaConnect should standardize worker thread name

[ https://issues.apache.org/jira/browse/KAFKA-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783917#comment-16783917 ] ASF GitHub Bot commented on KAFKA-7880: --- rhauch commented on pull request #6275: KAFKA-7880:Naming

[jira] [Updated] (KAFKA-7880) KafkaConnect should standardize worker thread name

[ https://issues.apache.org/jira/browse/KAFKA-7880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-7880: - Fix Version/s: 2.2.1 > KafkaConnect should standardize worker thread name >

[jira] [Resolved] (KAFKA-8002) Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets

[ https://issues.apache.org/jira/browse/KAFKA-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8002. Resolution: Fixed Fix Version/s: 2.1.2 2.0.2

[jira] [Commented] (KAFKA-8022) Flaky Test RequestQuotaTest#testExemptRequestTime

[ https://issues.apache.org/jira/browse/KAFKA-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783838#comment-16783838 ] Jun Rao commented on KAFKA-8022: The fsync to ZK txn log can take 10+ secs. Filed

[jira] [Assigned] (KAFKA-8022) Flaky Test RequestQuotaTest#testExemptRequestTime

[ https://issues.apache.org/jira/browse/KAFKA-8022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao reassigned KAFKA-8022: -- Assignee: Jun Rao > Flaky Test RequestQuotaTest#testExemptRequestTime >

[jira] [Created] (KAFKA-8039) Flaky Test SaslAuthenticatorTest#testCannotReauthenticateAgainFasterThanOneSecond

Matthias J. Sax created KAFKA-8039: -- Summary: Flaky Test SaslAuthenticatorTest#testCannotReauthenticateAgainFasterThanOneSecond Key: KAFKA-8039 URL: https://issues.apache.org/jira/browse/KAFKA-8039

[jira] [Created] (KAFKA-8038) Flaky Test SslTransportLayerTest#testCloseSsl

Matthias J. Sax created KAFKA-8038: -- Summary: Flaky Test SslTransportLayerTest#testCloseSsl Key: KAFKA-8038 URL: https://issues.apache.org/jira/browse/KAFKA-8038 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783818#comment-16783818 ] Matthias J. Sax commented on KAFKA-3729: [~yuzhih...@gmail.com] The ticket is unassigned. Feel

[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 ] Matthias J. Sax updated KAFKA-7663: --- Description: I have implemented a StreamBuilder#{{addGlobalStore}} supplying a custom

[jira] [Created] (KAFKA-8037) KTable restore may load bad data

Matthias J. Sax created KAFKA-8037: -- Summary: KTable restore may load bad data Key: KAFKA-8037 URL: https://issues.apache.org/jira/browse/KAFKA-8037 Project: Kafka Issue Type: Improvement

[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 ] Matthias J. Sax updated KAFKA-7663: --- Description: I have implemented a StreamBuilder#{{addGlobalStore}} supplying a custom

[jira] [Commented] (KAFKA-8002) Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets

[ https://issues.apache.org/jira/browse/KAFKA-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783790#comment-16783790 ] ASF GitHub Bot commented on KAFKA-8002: --- hachikuji commented on pull request #6364: KAFKA-8002: Log

[jira] [Commented] (KAFKA-3729) Auto-configure non-default SerDes passed alongside the topology builder

[ https://issues.apache.org/jira/browse/KAFKA-3729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783778#comment-16783778 ] Ted Yu commented on KAFKA-3729: --- I wonder if a third person can work on this - considering the lack of

[jira] [Commented] (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:comment-tabpanel=16783754#comment-16783754 ] John Roesler commented on KAFKA-7895: - Hi, [~mbragg], Sorry for the delay. Thanks for the

[jira] [Updated] (KAFKA-5998) /.checkpoint.tmp Not found exception

[ https://issues.apache.org/jira/browse/KAFKA-5998?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Adrian McCague updated KAFKA-5998: -- Affects Version/s: 2.1.1 > /.checkpoint.tmp Not found exception >

[jira] [Assigned] (KAFKA-7969) Flaky Test DescribeConsumerGroupTest#testDescribeOffsetsOfExistingGroupWithNoMembers

[ https://issues.apache.org/jira/browse/KAFKA-7969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7969: -- Assignee: (was: Stanislav Kozlovski) > Flaky Test >

[jira] [Assigned] (KAFKA-7976) Flaky Test DynamicBrokerReconfigurationTest#testUncleanLeaderElectionEnable

[ https://issues.apache.org/jira/browse/KAFKA-7976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski reassigned KAFKA-7976: -- Assignee: (was: Stanislav Kozlovski) > Flaky Test

[jira] [Updated] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-7312: - Fix Version/s: (was: 2.2.0) 2.2.1 2.3.0 > Transient failure in

[jira] [Resolved] (KAFKA-7651) Flaky test SaslSslAdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7651. -- Resolution: Fixed Fix Version/s: 2.2.1 2.1.2 2.0.2 This

[jira] [Resolved] (KAFKA-7312) Transient failure in kafka.api.AdminClientIntegrationTest.testMinimumRequestTimeouts

[ https://issues.apache.org/jira/browse/KAFKA-7312?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7312. -- Resolution: Fixed Fix Version/s: (was: 2.3.0) 2.1.2

[jira] [Commented] (KAFKA-7965) Flaky Test ConsumerBounceTest#testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup

[ https://issues.apache.org/jira/browse/KAFKA-7965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783640#comment-16783640 ] Matthias J. Sax commented on KAFKA-7965: One more:

[jira] [Commented] (KAFKA-8008) Clients unable to connect and replicas are not able to connect to each other

[ https://issues.apache.org/jira/browse/KAFKA-8008?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783530#comment-16783530 ] Michael Kemmerer commented on KAFKA-8008: - Same here. I have 3 clusters on the same V-Net in

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Affects Version/s: (was: 1.0.2) > Log dir reassignment on followers fails with

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Description: When changing a partition's log directories for a follower broker, we 

[jira] [Updated] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

[ https://issues.apache.org/jira/browse/KAFKA-8036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stanislav Kozlovski updated KAFKA-8036: --- Affects Version/s: (was: 1.1.0) 1.1.1 > Log dir

[jira] [Created] (KAFKA-8036) Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election

Stanislav Kozlovski created KAFKA-8036: -- Summary: Log dir reassignment on followers fails with FileNotFoundException for the leader epoch cache on leader election Key: KAFKA-8036 URL:

[jira] [Assigned] (KAFKA-7986) distinguish the logging from different ZooKeeperClient instances

[ https://issues.apache.org/jira/browse/KAFKA-7986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lambdaliu reassigned KAFKA-7986: Assignee: (was: lambdaliu) > distinguish the logging from different ZooKeeperClient instances

[jira] [Commented] (KAFKA-8010) kafka-configs.sh does not allow setting config with an equal in the value

[ https://issues.apache.org/jira/browse/KAFKA-8010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783385#comment-16783385 ] Mickael Maison commented on KAFKA-8010: --- Using single quotes does not work either. >

[jira] [Updated] (KAFKA-8035) Add tests for generic bounds for KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Description: During the work on KAFKA-4217, it was discovered that some combinations of Java

[jira] [Updated] (KAFKA-8035) Add tests for generics in KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Summary: Add tests for generics in KStream API (was: Add tests for generic bounds for KStream

[jira] [Updated] (KAFKA-8035) Add tests for generic bounds for KStream API

[ https://issues.apache.org/jira/browse/KAFKA-8035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8035: - Description: During the work on KAFKA-4217, it was discovered that some combinations of Java

[jira] [Commented] (KAFKA-7992) Add a server start time metric

[ https://issues.apache.org/jira/browse/KAFKA-7992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783349#comment-16783349 ] Stanislav Kozlovski commented on KAFKA-7992: Thanks Lee, apologies for forgetting to add it

[jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783342#comment-16783342 ] ASF GitHub Bot commented on KAFKA-7799: --- ijuma commented on pull request #6277: KAFKA-7799; Use

[jira] [Commented] (KAFKA-7799) Fix flaky test RestServerTest.testCORSEnabled

[ https://issues.apache.org/jira/browse/KAFKA-7799?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783343#comment-16783343 ] ASF GitHub Bot commented on KAFKA-7799: --- ijuma commented on pull request #6276: KAFKA-7799; Use

[jira] [Created] (KAFKA-8035) Add tests for generic bounds for KStream API

Bruno Cadonna created KAFKA-8035: Summary: Add tests for generic bounds for KStream API Key: KAFKA-8035 URL: https://issues.apache.org/jira/browse/KAFKA-8035 Project: Kafka Issue Type: Test

[jira] [Commented] (KAFKA-8034) Replace DeleteTopics request/response with automated protocol

[ https://issues.apache.org/jira/browse/KAFKA-8034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783252#comment-16783252 ] ASF GitHub Bot commented on KAFKA-8034: --- mimaison commented on pull request #6366: KAFKA-8034: Use

[jira] [Commented] (KAFKA-8002) Replica reassignment to new log dir may not complete if future and current replicas segment files have different base offsets

[ https://issues.apache.org/jira/browse/KAFKA-8002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16783081#comment-16783081 ] ASF GitHub Bot commented on KAFKA-8002: --- bob-barrett commented on pull request #6364: KAFKA-8002: