[jira] [Commented] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory

[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946467#comment-16946467 ] linking12 commented on KAFKA-8898: -- code:    

[jira] [Updated] (KAFKA-8898) if there is no message for poll, kafka consumer also apply memory

[ https://issues.apache.org/jira/browse/KAFKA-8898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] linking12 updated KAFKA-8898: - Attachment: image-2019-10-08-12-07-37-328.png > if there is no message for poll, kafka consumer also

[jira] [Commented] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946465#comment-16946465 ] Ivan Yurchenko commented on KAFKA-8206: --- [~guozhang] yes, I will do this. > A consumer can't

[jira] [Commented] (KAFKA-8272) Changed(De)Serializer does not forward configure() call

[ https://issues.apache.org/jira/browse/KAFKA-8272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946418#comment-16946418 ] ASF GitHub Bot commented on KAFKA-8272: --- mjsax commented on pull request #6614: [WIP -- do not

[jira] [Commented] (KAFKA-8939) Flaky test ReassignPartitionsClusterTest#shouldTriggerReassignmentWithZnodePrecedenceOnControllerStartup

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

[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: --- Labels: flaky-test (was: ) > Flaky test >

[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: --- Component/s: unit tests security core > Flaky test >

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

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

[jira] [Updated] (KAFKA-8995) Add new metric on broker to illustrate produce request compression percentage

[ https://issues.apache.org/jira/browse/KAFKA-8995?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8995: - Reporter: Jun Rao (was: Guozhang Wang) > Add new metric on broker to illustrate produce request

[jira] [Created] (KAFKA-8995) Add new metric on broker to illustrate produce request compression percentage

Guozhang Wang created KAFKA-8995: Summary: Add new metric on broker to illustrate produce request compression percentage Key: KAFKA-8995 URL: https://issues.apache.org/jira/browse/KAFKA-8995 Project:

[jira] [Assigned] (KAFKA-8994) Streams should expose standby replication information & allow stale reads of state store

[ https://issues.apache.org/jira/browse/KAFKA-8994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar reassigned KAFKA-8994: - Assignee: Vinoth Chandar > Streams should expose standby replication information &

[jira] [Created] (KAFKA-8994) Streams should expose standby replication information & allow stale reads of state store

Vinoth Chandar created KAFKA-8994: - Summary: Streams should expose standby replication information & allow stale reads of state store Key: KAFKA-8994 URL: https://issues.apache.org/jira/browse/KAFKA-8994

[jira] [Updated] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8206: - Labels: needs-kip (was: ) > A consumer can't discover new group coordinator when the cluster

[jira] [Commented] (KAFKA-8206) A consumer can't discover new group coordinator when the cluster was partly restarted

[ https://issues.apache.org/jira/browse/KAFKA-8206?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946323#comment-16946323 ] Guozhang Wang commented on KAFKA-8206: -- [~ivanyu] Thanks for the PR, I think your approach is

[jira] [Resolved] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle

[ https://issues.apache.org/jira/browse/KAFKA-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar resolved KAFKA-8839. --- Resolution: Fixed Closing since the PR has been merged > Improve logging in Kafka Streams

[jira] [Updated] (KAFKA-8839) Improve logging in Kafka Streams around debugging task lifecycle

[ https://issues.apache.org/jira/browse/KAFKA-8839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vinoth Chandar updated KAFKA-8839: -- Fix Version/s: 2.4.0 > Improve logging in Kafka Streams around debugging task lifecycle >

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946305#comment-16946305 ] ASF GitHub Bot commented on KAFKA-5488: --- mjsax commented on pull request #6164: KAFKA-5488: A

[jira] [Commented] (KAFKA-5488) KStream.branch should not return a Array of streams we have to access by known index

[ https://issues.apache.org/jira/browse/KAFKA-5488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946304#comment-16946304 ] Matthias J. Sax commented on KAFKA-5488: The corresponding KIP was inactive for a long time, and

[jira] [Assigned] (KAFKA-8432) Add static membership to Sticky assignor

[ https://issues.apache.org/jira/browse/KAFKA-8432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen reassigned KAFKA-8432: -- Assignee: (was: Boyang Chen) > Add static membership to Sticky assignor >

[jira] [Commented] (KAFKA-7245) Deprecate WindowStore#put(key, value)

[ https://issues.apache.org/jira/browse/KAFKA-7245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946280#comment-16946280 ] ASF GitHub Bot commented on KAFKA-7245: --- mjsax commented on pull request #7105: KAFKA-7245

[jira] [Commented] (KAFKA-8972) Toggle bulkloading hit NPE

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946262#comment-16946262 ] Sophie Blee-Goldman commented on KAFKA-8972: [~bchen225242] I've also seen this fail with a

[jira] [Created] (KAFKA-8993) Add an EOS performance test suite similar to ProducerPerformance

Boyang Chen created KAFKA-8993: -- Summary: Add an EOS performance test suite similar to ProducerPerformance Key: KAFKA-8993 URL: https://issues.apache.org/jira/browse/KAFKA-8993 Project: Kafka

[jira] [Updated] (KAFKA-8972) Toggle bulkloading hit NPE

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8972: --- Description: test `test_broker_type_bounce` could sometimes fail due to NPE in changelog

[jira] [Updated] (KAFKA-8972) Toggle bulkloading hit NPE

[ https://issues.apache.org/jira/browse/KAFKA-8972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Boyang Chen updated KAFKA-8972: --- Summary: Toggle bulkloading hit NPE (was: Reduce

[jira] [Commented] (KAFKA-8973) Give user options to turn off linger.ms/batch.size constraint

[ https://issues.apache.org/jira/browse/KAFKA-8973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946232#comment-16946232 ] Boyang Chen commented on KAFKA-8973: I guess it's not an action item that makes sense, closing it. >

[jira] [Commented] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946208#comment-16946208 ] Guozhang Wang commented on KAFKA-8104: -- [~nizhikov] Thanks for picking this up, I think this issue

[jira] [Commented] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946177#comment-16946177 ] ASF GitHub Bot commented on KAFKA-8262: --- guozhangwang commented on pull request #7457: KAFKA-8262,

[jira] [Updated] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8262: - Fix Version/s: 2.3.1 > Flaky Test MetricsIntegrationTest#testStreamMetric >

[jira] [Updated] (KAFKA-8263) Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore

[ https://issues.apache.org/jira/browse/KAFKA-8263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-8263: - Fix Version/s: 2.3.1 > Flaky Test MetricsIntegrationTest#testStreamMetricOfWindowStore >

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

[ https://issues.apache.org/jira/browse/KAFKA-8940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8940: --- Summary: Flaky Test SmokeTestDriverIntegrationTest.shouldWorkWithRebalance (was:

[jira] [Updated] (KAFKA-8951) Avoid unnecessary rebalances and downtime for "safe" partitions

[ https://issues.apache.org/jira/browse/KAFKA-8951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8951: --- Affects Version/s: 2.4.0 > Avoid unnecessary rebalances and downtime for "safe"

[jira] [Assigned] (KAFKA-8992) Don't expose Errors in `RemoveMemberFromGroupResult`

[ https://issues.apache.org/jira/browse/KAFKA-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson reassigned KAFKA-8992: -- Assignee: Boyang Chen (was: Jason Gustafson) > Don't expose Errors in

[jira] [Updated] (KAFKA-8992) Don't expose Errors in `RemoveMemberFromGroupResult`

[ https://issues.apache.org/jira/browse/KAFKA-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8992: --- Description: The type `RemoveMemberFromGroupResult` exposes `Errors` from `topLevelError`.

[jira] [Commented] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946114#comment-16946114 ] ASF GitHub Bot commented on KAFKA-8104: --- nizhikov commented on pull request #7460: KAFKA-8104:

[jira] [Updated] (KAFKA-8992) Don't expose Errors in `RemoveMemberFromGroupResult`

[ https://issues.apache.org/jira/browse/KAFKA-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-8992: --- Summary: Don't expose Errors in `RemoveMemberFromGroupResult` (was: Don't expose Errors in

[jira] [Commented] (KAFKA-8992) Don't expose Errors in Admin result objects

[ https://issues.apache.org/jira/browse/KAFKA-8992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946112#comment-16946112 ] Jason Gustafson commented on KAFKA-8992: My mistake. It is just `RemoveMemberFromGroupResult`

[jira] [Updated] (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 ] Matthias J. Sax updated KAFKA-8147: --- Description: The streams DSL does not provide a way to configure the changelog topic created

[jira] [Created] (KAFKA-8992) Don't expose Errors in Admin result objects

Jason Gustafson created KAFKA-8992: -- Summary: Don't expose Errors in Admin result objects Key: KAFKA-8992 URL: https://issues.apache.org/jira/browse/KAFKA-8992 Project: Kafka Issue Type:

[jira] [Updated] (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 ] Matthias J. Sax updated KAFKA-8147: --- Labels: kip (was: needs-kip) > Add changelog topic configuration to KTable suppress >

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Description: With KIP-429 the suspend/resume of tasks may have minimal gains while

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Description: With KIP-429 the suspend/resume of tasks may have minimal gains while

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Affects Version/s: 3.0.0 > Investigate removing EAGER & cleaning up task suspension

[jira] [Updated] (KAFKA-8575) Investigate removing EAGER & cleaning up task suspension (part 8)

[ https://issues.apache.org/jira/browse/KAFKA-8575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8575: --- Summary: Investigate removing EAGER & cleaning up task suspension (part 8) (was:

[jira] [Updated] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness (part 7)

[ https://issues.apache.org/jira/browse/KAFKA-8510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sophie Blee-Goldman updated KAFKA-8510: --- Component/s: (was: consumer) > Update StreamsPartitionAssignor to use the

[jira] [Updated] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6498: --- Description: RocksDB's own stats can be programmatically exposed via

[jira] [Updated] (KAFKA-6498) Add RocksDB statistics via Streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-6498?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6498: --- Labels: kip (was: needs-kip) > Add RocksDB statistics via Streams metrics >

[jira] [Comment Edited] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946061#comment-16946061 ] Nikolay Izhikov edited comment on KAFKA-8104 at 10/7/19 5:28 PM: -

[jira] [Commented] (KAFKA-8104) Consumer cannot rejoin to the group after rebalancing

[ https://issues.apache.org/jira/browse/KAFKA-8104?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946061#comment-16946061 ] Nikolay Izhikov commented on KAFKA-8104: Reproducer simplified and updated. > Consumer cannot

[jira] [Resolved] (KAFKA-6263) Expose metric for group metadata loading duration

[ https://issues.apache.org/jira/browse/KAFKA-6263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6263. -- Fix Version/s: 2.4.0 Resolution: Fixed > Expose metric for group metadata loading duration >

[jira] [Commented] (KAFKA-8179) Incremental Rebalance Protocol for Kafka Consumer

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

[jira] [Commented] (KAFKA-8985) Use flexibleVersions with LeaderAndIsr, UMR, etc., and improve RequestResponseTest coverage

[ https://issues.apache.org/jira/browse/KAFKA-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946000#comment-16946000 ] ASF GitHub Bot commented on KAFKA-8985: --- hachikuji commented on pull request #7453: KAFKA-8985; Add

[jira] [Resolved] (KAFKA-8985) Use flexibleVersions with LeaderAndIsr, UMR, etc., and improve RequestResponseTest coverage

[ https://issues.apache.org/jira/browse/KAFKA-8985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-8985. Fix Version/s: 2.4.0 Assignee: Jason Gustafson (was: Colin McCabe)

[jira] [Commented] (KAFKA-8262) Flaky Test MetricsIntegrationTest#testStreamMetric

[ https://issues.apache.org/jira/browse/KAFKA-8262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945965#comment-16945965 ] ASF GitHub Bot commented on KAFKA-8262: --- cadonna commented on pull request #7457: KAFKA-8262,

[jira] [Commented] (KAFKA-8989) Embedded broker could not be reached in unit test

[ https://issues.apache.org/jira/browse/KAFKA-8989?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945859#comment-16945859 ] Bruno Cadonna commented on KAFKA-8989: -- [~bchen225242] Could you please add some description or even

[jira] [Resolved] (KAFKA-8934) Introduce Instance-level Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna resolved KAFKA-8934. -- Fix Version/s: 2.4.0 Resolution: Fixed > Introduce Instance-level Metrics >

[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=16945729#comment-16945729 ] Bruno Cadonna commented on KAFKA-8977: -- Thank you for picking this up. IMO we should mock

[jira] [Resolved] (KAFKA-7471) Multiple Consumer Group Management (Describe, Reset, Delete)

[ https://issues.apache.org/jira/browse/KAFKA-7471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7471. -- Fix Version/s: 2.4.0 Resolution: Fixed > Multiple Consumer Group Management (Describe, Reset,

[jira] [Resolved] (KAFKA-7800) Extend Admin API to support dynamic application log levels

[ https://issues.apache.org/jira/browse/KAFKA-7800?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-7800. -- Fix Version/s: 2.4.0 Resolution: Fixed > Extend Admin API to support dynamic application log

[jira] [Resolved] (KAFKA-8696) Clean up Sum/Count/Total metrics

[ https://issues.apache.org/jira/browse/KAFKA-8696?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8696. -- Resolution: Fixed > Clean up Sum/Count/Total metrics > > >

[jira] [Commented] (KAFKA-8943) Move SecurityProviderCreator to a public package

[ https://issues.apache.org/jira/browse/KAFKA-8943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945698#comment-16945698 ] Rajini Sivaram commented on KAFKA-8943: --- [~mprsai] Yes, please go ahead. Thanks. > Move

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

[ https://issues.apache.org/jira/browse/KAFKA-8555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945690#comment-16945690 ] Levani Kokhreidze commented on KAFKA-8555: --

[jira] [Commented] (KAFKA-8686) Flaky test ExampleConnectIntegrationTest#testSinkConnector

[ https://issues.apache.org/jira/browse/KAFKA-8686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945691#comment-16945691 ] Levani Kokhreidze commented on KAFKA-8686: --

[jira] [Resolved] (KAFKA-8669) Add java security providers in Kafka Security config

[ https://issues.apache.org/jira/browse/KAFKA-8669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8669. -- Fix Version/s: 2.4.0 Assignee: Sai Sandeep Resolution: Fixed Fixed in

[jira] [Updated] (KAFKA-8907) Return topic configs in CreateTopics response

[ https://issues.apache.org/jira/browse/KAFKA-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar updated KAFKA-8907: - Reviewer: Manikumar (was: Manikumar Reddy) > Return topic configs in CreateTopics response >

[jira] [Resolved] (KAFKA-8907) Return topic configs in CreateTopics response

[ https://issues.apache.org/jira/browse/KAFKA-8907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8907. -- Reviewer: Manikumar Reddy Resolution: Fixed > Return topic configs in CreateTopics response >

[jira] [Assigned] (KAFKA-7500) MirrorMaker 2.0 (KIP-382)

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar reassigned KAFKA-7500: Assignee: Ryanne Dolan (was: Manikumar) > MirrorMaker 2.0 (KIP-382) > -

[jira] [Commented] (KAFKA-8233) Helper classes to make it simpler to write test logic with TopologyTestDriver

[ https://issues.apache.org/jira/browse/KAFKA-8233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945660#comment-16945660 ] ASF GitHub Bot commented on KAFKA-8233: --- mjsax commented on pull request #7378: KAFKA-8233:

[jira] [Commented] (KAFKA-8690) Flakey test ConnectWorkerIntegrationTest#testAddAndRemoveWorke

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

[jira] [Commented] (KAFKA-8686) Flaky test ExampleConnectIntegrationTest#testSinkConnector

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

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

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

[jira] [Commented] (KAFKA-8555) Flaky test ExampleConnectIntegrationTest#testSourceConnector

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