[jira] [Commented] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952558#comment-16952558 ] Manas Ray commented on KAFKA-1843: -- Is there any plan to fix this issue. We are still fa

[jira] [Assigned] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-9048: Assignee: Guozhang Wang > Improve scalability in number of partitions in replica fetcher >

[jira] [Commented] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952524#comment-16952524 ] ASF GitHub Bot commented on KAFKA-8897: --- mjsax commented on pull request #7483: KAF

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952523#comment-16952523 ] Matthias J. Sax commented on KAFKA-8025: [https://builds.apache.org/job/kafka-pr-

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

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952520#comment-16952520 ] Matthias J. Sax commented on KAFKA-9000: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9019) Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952518#comment-16952518 ] Matthias J. Sax commented on KAFKA-9019: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9041) Flaky Test LogCleanerIntegrationTest#testIsThreadFailed

[ https://issues.apache.org/jira/browse/KAFKA-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952519#comment-16952519 ] Matthias J. Sax commented on KAFKA-9041: [https://builds.apache.org/job/kafka-pr-

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

[ https://issues.apache.org/jira/browse/KAFKA-9000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952517#comment-16952517 ] Matthias J. Sax commented on KAFKA-9000: [https://builds.apache.org/job/kafka-pr-

[jira] [Assigned] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Senthilnathan Muthusamy reassigned KAFKA-7061: -- Assignee: Senthilnathan Muthusamy (was: Ning Liu) > Enhanced log comp

[jira] [Updated] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet updated KAFKA-9048: Description: https://issues.apache.org/jira/browse/KAFKA-9039  ([https://github.com/apache/

[jira] [Updated] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet updated KAFKA-9048: Description: https://issues.apache.org/jira/browse/KAFKA-9039  ([https://github.com/apache/

[jira] [Updated] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet updated KAFKA-9048: Description: https://issues.apache.org/jira/browse/KAFKA-9039  ([https://github.com/apache/

[jira] [Created] (KAFKA-9048) Improve partition scalability in replica fetcher

Lucas Bradstreet created KAFKA-9048: --- Summary: Improve partition scalability in replica fetcher Key: KAFKA-9048 URL: https://issues.apache.org/jira/browse/KAFKA-9048 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-9048) Improve scalability in number of partitions in replica fetcher

[ https://issues.apache.org/jira/browse/KAFKA-9048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lucas Bradstreet updated KAFKA-9048: Summary: Improve scalability in number of partitions in replica fetcher (was: Improve part

[jira] [Commented] (KAFKA-7061) Enhanced log compaction

[ https://issues.apache.org/jira/browse/KAFKA-7061?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952501#comment-16952501 ] ASF GitHub Bot commented on KAFKA-7061: --- senthilm-ms commented on pull request #752

[jira] [Resolved] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dhruvil Shah resolved KAFKA-8125. - Resolution: Duplicate > Check for topic existence in CreateTopicsRequest prior to creating replic

[jira] [Commented] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952415#comment-16952415 ] Dhruvil Shah commented on KAFKA-8125: - Yeah, I'll close it as duplicate as the issue

[jira] [Updated] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

[ https://issues.apache.org/jira/browse/KAFKA-9014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9014: - Fix Version/s: 2.5.0 > AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll >

[jira] [Updated] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8945: - Fix Version/s: 2.5.0 > Incorrect null check in the constructor for ConnectorHealth and AbstractSt

[jira] [Commented] (KAFKA-8047) remove KafkaMbean when network close

[ https://issues.apache.org/jira/browse/KAFKA-8047?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952410#comment-16952410 ] ASF GitHub Bot commented on KAFKA-8047: --- alex-dukhno commented on pull request #752

[jira] [Created] (KAFKA-9047) AdminClient group operations may not respect backoff

Jason Gustafson created KAFKA-9047: -- Summary: AdminClient group operations may not respect backoff Key: KAFKA-9047 URL: https://issues.apache.org/jira/browse/KAFKA-9047 Project: Kafka Issue

[jira] [Commented] (KAFKA-8370) Kafka Connect should check for existence of internal topics before attempting to create them

[ https://issues.apache.org/jira/browse/KAFKA-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952395#comment-16952395 ] Chris Egerton commented on KAFKA-8370: -- Looks like https://issues.apache.org/jira/br

[jira] [Commented] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952393#comment-16952393 ] Chris Egerton commented on KAFKA-8125: -- Now that https://issues.apache.org/jira/brow

[jira] [Commented] (KAFKA-9046) Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors

[ https://issues.apache.org/jira/browse/KAFKA-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952389#comment-16952389 ] Chris Egerton commented on KAFKA-9046: -- If the PR is accepted, we should add a note

[jira] [Commented] (KAFKA-8819) Plugin path for converters not working as intended

[ https://issues.apache.org/jira/browse/KAFKA-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952385#comment-16952385 ] Randall Hauch commented on KAFKA-8819: -- Also related to KAFKA-8340 > Plugin path fo

[jira] [Commented] (KAFKA-9046) Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors

[ https://issues.apache.org/jira/browse/KAFKA-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952386#comment-16952386 ] ASF GitHub Bot commented on KAFKA-9046: --- C0urante commented on pull request #7525:

[jira] [Commented] (KAFKA-8819) Plugin path for converters not working as intended

[ https://issues.apache.org/jira/browse/KAFKA-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952383#comment-16952383 ] Randall Hauch commented on KAFKA-8819: -- See also https://github.com/apache/kafka/pul

[jira] [Commented] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952371#comment-16952371 ] Chris Egerton commented on KAFKA-8947: -- Opened the requested backport-viable PR at 

[jira] [Commented] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952369#comment-16952369 ] ASF GitHub Bot commented on KAFKA-8945: --- C0urante commented on pull request #7524:

[jira] [Commented] (KAFKA-8819) Plugin path for converters not working as intended

[ https://issues.apache.org/jira/browse/KAFKA-8819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952364#comment-16952364 ] ASF GitHub Bot commented on KAFKA-8819: --- mageshn commented on pull request #7236: K

[jira] [Updated] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8947: - Fix Version/s: (was: 2.3.1) 2.3.2 > Connect framework incorrectly instanti

[jira] [Resolved] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8945. -- Resolution: Fixed > Incorrect null check in the constructor for ConnectorHealth and AbstractSta

[jira] [Resolved] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-8947. -- Resolution: Fixed > Connect framework incorrectly instantiates TaskStates for REST extensions >

[jira] [Updated] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8945: - Fix Version/s: 2.3.1 2.4.0 > Incorrect null check in the constructor for Conne

[jira] [Reopened] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch reopened KAFKA-8947: -- > Connect framework incorrectly instantiates TaskStates for REST extensions > -

[jira] [Updated] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8945: - Fix Version/s: (was: 2.3.1) 2.3.2 > Incorrect null check in the constructo

[jira] [Assigned] (KAFKA-8897) Increase Version of RocksDB

[ https://issues.apache.org/jira/browse/KAFKA-8897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-8897: -- Assignee: Bruno Cadonna > Increase Version of RocksDB > --- >

[jira] [Resolved] (KAFKA-9030) Document Instance-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-9030. Fix Version/s: 2.4.0 Resolution: Fixed > Document Instance-level Metrics > -

[jira] [Assigned] (KAFKA-9030) Document Instance-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-9030: -- Assignee: Bruno Cadonna > Document Instance-level Metrics > --

[jira] [Commented] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952357#comment-16952357 ] Randall Hauch commented on KAFKA-8947: -- The implementation is also related to KAFKA-

[jira] [Commented] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952356#comment-16952356 ] Randall Hauch commented on KAFKA-8947: -- [~ChrisEgerton], I've merged this to the `tr

[jira] [Updated] (KAFKA-8947) Connect framework incorrectly instantiates TaskStates for REST extensions

[ https://issues.apache.org/jira/browse/KAFKA-8947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-8947: - Fix Version/s: 2.3.1 2.4.0 > Connect framework incorrectly instantiates TaskSt

[jira] [Commented] (KAFKA-8945) Incorrect null check in the constructor for ConnectorHealth and AbstractState

[ https://issues.apache.org/jira/browse/KAFKA-8945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952340#comment-16952340 ] ASF GitHub Bot commented on KAFKA-8945: --- rhauch commented on pull request #7392: KA

[jira] [Commented] (KAFKA-8370) Kafka Connect should check for existence of internal topics before attempting to create them

[ https://issues.apache.org/jira/browse/KAFKA-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952337#comment-16952337 ] Chris Egerton commented on KAFKA-8370: -- To clarify, adding a check-before-create wou

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952336#comment-16952336 ] Guozhang Wang commented on KAFKA-8025: -- {code} Stacktrace java.lang.AssertionError:

[jira] [Resolved] (KAFKA-9033) Change default client-id in consumer / producer to be more meaningful

[ https://issues.apache.org/jira/browse/KAFKA-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-9033. Fix Version/s: 2.4.0 Resolution: Fixed > Change default client-id in consumer / prod

[jira] [Commented] (KAFKA-9033) Change default client-id in consumer / producer to be more meaningful

[ https://issues.apache.org/jira/browse/KAFKA-9033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952328#comment-16952328 ] ASF GitHub Bot commented on KAFKA-9033: --- hachikuji commented on pull request #7514:

[jira] [Resolved] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

[ https://issues.apache.org/jira/browse/KAFKA-9014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-9014. -- Reviewer: Randall Hauch Resolution: Fixed Merged onto the `trunk`, `2.3`, `2.2`, `2.1`, `

[jira] [Updated] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

[ https://issues.apache.org/jira/browse/KAFKA-9014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch updated KAFKA-9014: - Fix Version/s: 2.3.1 2.4.0 2.2.2 2.1.2

[jira] [Comment Edited] (KAFKA-8370) Kafka Connect should check for existence of internal topics before attempting to create them

[ https://issues.apache.org/jira/browse/KAFKA-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952321#comment-16952321 ] Chris Egerton edited comment on KAFKA-8370 at 10/15/19 9:41 PM: ---

[jira] [Commented] (KAFKA-8370) Kafka Connect should check for existence of internal topics before attempting to create them

[ https://issues.apache.org/jira/browse/KAFKA-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952321#comment-16952321 ] Chris Egerton commented on KAFKA-8370: -- The {{InvalidReplicationFactor}} example is

[jira] [Commented] (KAFKA-8125) Check for topic existence in CreateTopicsRequest prior to creating replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-8125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952313#comment-16952313 ] Chris Egerton commented on KAFKA-8125: -- [~huxi_2b] [~lbradstreet] [~dhruvilshah] [~c

[jira] [Commented] (KAFKA-9030) Document Instance-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-9030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952310#comment-16952310 ] ASF GitHub Bot commented on KAFKA-9030: --- mjsax commented on pull request #7501: KAF

[jira] [Commented] (KAFKA-9046) Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors

[ https://issues.apache.org/jira/browse/KAFKA-9046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952294#comment-16952294 ] Chris Egerton commented on KAFKA-9046: -- Although backwards compatibility was broken

[jira] [Commented] (KAFKA-9014) AssertionError thrown by SourceRecordWriteCounter when SourceTask.poll returns an empty list

[ https://issues.apache.org/jira/browse/KAFKA-9014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952290#comment-16952290 ] ASF GitHub Bot commented on KAFKA-9014: --- rhauch commented on pull request #7491: KA

[jira] [Commented] (KAFKA-8370) Kafka Connect should check for existence of internal topics before attempting to create them

[ https://issues.apache.org/jira/browse/KAFKA-8370?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952285#comment-16952285 ] Randall Hauch commented on KAFKA-8370: -- I agree that adding a check for the existenc

[jira] [Created] (KAFKA-9046) Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors

Chris Egerton created KAFKA-9046: Summary: Connect worker configs require undocumented 'admin.' prefix to configure DLQ for connectors Key: KAFKA-9046 URL: https://issues.apache.org/jira/browse/KAFKA-9046

[jira] [Commented] (KAFKA-8025) Flaky Test RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest#shouldForwardAllDbOptionsCalls

[ https://issues.apache.org/jira/browse/KAFKA-8025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952258#comment-16952258 ] Matthias J. Sax commented on KAFKA-8025: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-9041) Flaky Test LogCleanerIntegrationTest#testIsThreadFailed

[ https://issues.apache.org/jira/browse/KAFKA-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952257#comment-16952257 ] Matthias J. Sax commented on KAFKA-9041: [https://builds.apache.org/job/kafka-pr-

[jira] [Created] (KAFKA-9045) Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl

Matthias J. Sax created KAFKA-9045: -- Summary: Flaky Test DelegationTokenEndToEndAuthorizationTest#testNoDescribeProduceOrConsumeWithoutTopicDescribeAcl Key: KAFKA-9045 URL: https://issues.apache.org/jira/browse/K

[jira] [Commented] (KAFKA-9019) Flaky Test kafka.api.SslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-9019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952253#comment-16952253 ] Matthias J. Sax commented on KAFKA-9019: [https://builds.apache.org/job/kafka-pr-

[jira] [Updated] (KAFKA-8967) Flaky test kafka.api.SaslSslAdminClientIntegrationTest.testCreateTopicsResponseMetadataAndConfig

[ https://issues.apache.org/jira/browse/KAFKA-8967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8967: --- Issue Type: Test (was: Improvement) > Flaky test > kafka.api.SaslSslAdminClientIntegrationT

[jira] [Updated] (KAFKA-8122) Flaky Test EosIntegrationTest#shouldNotViolateEosIfOneTaskFailsWithState

[ https://issues.apache.org/jira/browse/KAFKA-8122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8122: --- Fix Version/s: (was: 2.5.0) 2.4.0 > Flaky Test EosIntegrationTest#shou

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

[ https://issues.apache.org/jira/browse/KAFKA-8769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu updated KAFKA-8769: -- Labels: needs-discussion needs-kip (was: ) > Consider computing stream time independently per key > --

[jira] [Commented] (KAFKA-8729) Augment ProduceResponse error messaging for specific culprit records

[ https://issues.apache.org/jira/browse/KAFKA-8729?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952237#comment-16952237 ] ASF GitHub Bot commented on KAFKA-8729: --- guozhangwang commented on pull request #75

[jira] [Assigned] (KAFKA-8581) Augment ProduceResponse error messaging for specific culprit records

[ https://issues.apache.org/jira/browse/KAFKA-8581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reassigned KAFKA-8581: Assignee: Tu Tran (was: Guozhang Wang) > Augment ProduceResponse error messaging for spec

[jira] [Commented] (KAFKA-3705) Support non-key joining in KTable

[ https://issues.apache.org/jira/browse/KAFKA-3705?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952212#comment-16952212 ] ASF GitHub Bot commented on KAFKA-3705: --- guozhangwang commented on pull request #37

[jira] [Assigned] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ryanne Dolan reassigned KAFKA-6080: --- Assignee: Ryanne Dolan > Transactional EoS for source connectors > -

[jira] [Commented] (KAFKA-6820) Improve on StreamsMetrics Public APIs

[ https://issues.apache.org/jira/browse/KAFKA-6820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952208#comment-16952208 ] ASF GitHub Bot commented on KAFKA-6820: --- guozhangwang commented on pull request #64

[jira] [Commented] (KAFKA-6080) Transactional EoS for source connectors

[ https://issues.apache.org/jira/browse/KAFKA-6080?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952205#comment-16952205 ] Ryanne Dolan commented on KAFKA-6080: - I'm thinking about this differently than you g

[jira] [Resolved] (KAFKA-5566) Flaky Test QueryableStateIntegrationTest.shouldAllowToQueryAfterThreadDied

[ https://issues.apache.org/jira/browse/KAFKA-5566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5566. -- Fix Version/s: (was: 1.0.0) 2.4.0 Resolution: Fixed > Flaky Test

[jira] [Resolved] (KAFKA-8700) Flaky Test QueryableStateIntegrationTest#queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8700. -- Assignee: Guozhang Wang Resolution: Fixed This is a duplicate of KAFKA-4222. > Flaky Tes

[jira] [Resolved] (KAFKA-4222) Flaky Test QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4222. -- Fix Version/s: (was: 0.11.0.0) 2.4.0 Assignee: Guozhang Wang

[jira] [Commented] (KAFKA-8909) Flaky Test ReassignPartitionsClusterTest#shouldPerformMultipleReassignmentOperationsOverVariousTopics

[ https://issues.apache.org/jira/browse/KAFKA-8909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952201#comment-16952201 ] Matthias J. Sax commented on KAFKA-8909: [https://builds.apache.org/job/kafka-pr-

[jira] [Commented] (KAFKA-4422) Drop support for Scala 2.10 (KIP-119)

[ https://issues.apache.org/jira/browse/KAFKA-4422?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952200#comment-16952200 ] ASF GitHub Bot commented on KAFKA-4422: --- guozhangwang commented on pull request #75

[jira] [Updated] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8813: --- Fix Version/s: (was: 2.3.2) > Race condition when creating topics and changing their conf

[jira] [Resolved] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8813. Fix Version/s: 2.4.0 2.3.2 Resolution: Fixed > Race condition whe

[jira] [Commented] (KAFKA-8813) Race condition when creating topics and changing their configuration

[ https://issues.apache.org/jira/browse/KAFKA-8813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952193#comment-16952193 ] ASF GitHub Bot commented on KAFKA-8813: --- hachikuji commented on pull request #7305:

[jira] [Commented] (KAFKA-8942) Document RocksDB metrics

[ https://issues.apache.org/jira/browse/KAFKA-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952188#comment-16952188 ] ASF GitHub Bot commented on KAFKA-8942: --- guozhangwang commented on pull request #74

[jira] [Resolved] (KAFKA-8942) Document RocksDB metrics

[ https://issues.apache.org/jira/browse/KAFKA-8942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8942. -- Fix Version/s: 2.4.0 Resolution: Fixed Issue resolved by pull request 7490 [https://gith

[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] [Updated] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Bukowinski updated KAFKA-9044: Description: I have several cluster running kafka 2.3.1 and this issue has affected all of

[jira] [Updated] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Bukowinski updated KAFKA-9044: Description: I have several cluster running kafka 2.3.1 and this issue has affected all of

[jira] [Updated] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

[ https://issues.apache.org/jira/browse/KAFKA-9044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Peter Bukowinski updated KAFKA-9044: Description: I have several cluster running kafka 2.3.1 and this issue has affected all of

[jira] [Created] (KAFKA-9044) Brokers occasionally (randomly?) dropping out of clusters

Peter Bukowinski created KAFKA-9044: --- Summary: Brokers occasionally (randomly?) dropping out of clusters Key: KAFKA-9044 URL: https://issues.apache.org/jira/browse/KAFKA-9044 Project: Kafka

[jira] [Commented] (KAFKA-8940) Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952157#comment-16952157 ] Guozhang Wang commented on KAFKA-8940: -- Failed again: at org.junit.Assert.f

[jira] [Commented] (KAFKA-4159) Allow overriding producer & consumer properties at the connector level

[ https://issues.apache.org/jira/browse/KAFKA-4159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16952104#comment-16952104 ] Randall Hauch commented on KAFKA-4159: -- This has been implemented as part of [KIP-4

[jira] [Resolved] (KAFKA-4280) Document REST resource for showing available connector plugin configs

[ https://issues.apache.org/jira/browse/KAFKA-4280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-4280. -- Resolution: Fixed The `GET /connector-plugins` endpoint has since been documented on https://k

[jira] [Resolved] (KAFKA-4278) Undocumented REST resources

[ https://issues.apache.org/jira/browse/KAFKA-4278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-4278. -- Resolution: Fixed These have since been documented. > Undocumented REST resources > --

[jira] [Resolved] (KAFKA-4598) Create new SourceTask commit callback method that takes offsets param

[ https://issues.apache.org/jira/browse/KAFKA-4598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-4598. -- Resolution: Implemented Marking as implemented via KAFKA-7500, via the `SourceTask.commitRecord

[jira] [Resolved] (KAFKA-5067) java.sql.SQLDataException on TimeStamp column when using AWS Redshift as a JDBC source

[ https://issues.apache.org/jira/browse/KAFKA-5067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5067. -- Resolution: Invalid Resolving as INVALID since the reported problem is not on an Apache Kafka

[jira] [Resolved] (KAFKA-5741) Prioritize threads in Connect distributed worker process

[ https://issues.apache.org/jira/browse/KAFKA-5741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5741. -- Resolution: Won't Fix Resolving as WONTFIX, since there is no clear indication that this is a p

[jira] [Resolved] (KAFKA-5740) Use separate file for HTTP logs

[ https://issues.apache.org/jira/browse/KAFKA-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5740. -- Resolution: Won't Fix Resolving as WONTFIX > Use separate file for HTTP logs > ---

[jira] [Resolved] (KAFKA-5828) Allow explicitly setting polling interval for Kafka connectors

[ https://issues.apache.org/jira/browse/KAFKA-5828?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5828. -- Resolution: Won't Fix Use quotas instead. > Allow explicitly setting polling interval for Kafk

[jira] [Resolved] (KAFKA-5938) Oracle jdbc-source-connector with kafka-connect distributed mode will result in http 500 error

[ https://issues.apache.org/jira/browse/KAFKA-5938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5938. -- Resolution: Invalid Resolving as INVALID since this issue appears to report a problem with a c

[jira] [Resolved] (KAFKA-7529) Kafka Connect JDBC doesn't push new records to Kafka Topic unless the connector is restarted

[ https://issues.apache.org/jira/browse/KAFKA-7529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-7529. -- Resolution: Invalid Resolving as INVALID since this issue does indeed appear to be on the Confl

[jira] [Commented] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

[ https://issues.apache.org/jira/browse/KAFKA-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951855#comment-16951855 ] bibin sebastian commented on KAFKA-8977: Got it. Glancing through the test cases/

[jira] [Commented] (KAFKA-8977) Remove MockStreamsMetrics Since it is not a Mock

[ https://issues.apache.org/jira/browse/KAFKA-8977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16951857#comment-16951857 ] bibin sebastian commented on KAFKA-8977: [~cadonna]^^ > Remove MockStreamsMetric

[jira] [Updated] (KAFKA-9043) Problem committing offsets when using consumer subscribe and assign method on different topics with same group.id

[ https://issues.apache.org/jira/browse/KAFKA-9043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Arndt updated KAFKA-9043: - Description: I am using a consumer with group.id "myGroup" on an *_empty_* topic "election" with

  1   2   >