[jira] [Commented] (KAFKA-8576) Consumer failed to join the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870040#comment-16870040 ] yanrui commented on KAFKA-8576: --- The problem is solved after the broker restarts. > Consumer failed to

[jira] [Comment Edited] (KAFKA-8576) Consumer failed to join the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870039#comment-16870039 ] yanrui edited comment on KAFKA-8576 at 6/22/19 3:56 AM: Is it possible that the

[jira] [Commented] (KAFKA-8576) Consumer failed to join the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870039#comment-16870039 ] yanrui commented on KAFKA-8576: --- Is it possible that the leaderAndIsr sent by the controller is lost

[jira] [Commented] (KAFKA-8576) Consumer failed to join the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16870022#comment-16870022 ] yanrui commented on KAFKA-8576: --- 2019-05-27 15:16:09 860 INFO

[jira] [Created] (KAFKA-8586) Source task producers silently fail to send records

Chris Egerton created KAFKA-8586: Summary: Source task producers silently fail to send records Key: KAFKA-8586 URL: https://issues.apache.org/jira/browse/KAFKA-8586 Project: Kafka Issue

[jira] [Assigned] (KAFKA-8586) Source task producers silently fail to send records

[ https://issues.apache.org/jira/browse/KAFKA-8586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton reassigned KAFKA-8586: Assignee: Chris Egerton > Source task producers silently fail to send records >

[jira] [Commented] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays

[ https://issues.apache.org/jira/browse/KAFKA-8584?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869968#comment-16869968 ] SuryaTeja Duggi commented on KAFKA-8584: Let me know if there is any thing else to know > Allow

[jira] [Assigned] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays

[ https://issues.apache.org/jira/browse/KAFKA-8584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] SuryaTeja Duggi reassigned KAFKA-8584: -- Assignee: SuryaTeja Duggi > Allow "bytes" type to generated a ByteBuffer rather than

[jira] [Created] (KAFKA-8585) Controller should make LeaderAndIsr updates optimistically

Jason Gustafson created KAFKA-8585: -- Summary: Controller should make LeaderAndIsr updates optimistically Key: KAFKA-8585 URL: https://issues.apache.org/jira/browse/KAFKA-8585 Project: Kafka

[jira] [Comment Edited] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869529#comment-16869529 ] William Greer edited comment on KAFKA-8574 at 6/21/19 11:13 PM: This is a

[jira] [Updated] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] William Greer updated KAFKA-8574: - Description: *Overview* While using EOS in Kafka Stream there is a race condition where the

[jira] [Created] (KAFKA-8584) Allow "bytes" type to generated a ByteBuffer rather than byte arrays

Guozhang Wang created KAFKA-8584: Summary: Allow "bytes" type to generated a ByteBuffer rather than byte arrays Key: KAFKA-8584 URL: https://issues.apache.org/jira/browse/KAFKA-8584 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-7500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869925#comment-16869925 ] Ryanne Dolan commented on KAFKA-7500: - [~abellemare] Thanks for trying it out. > 1) Are the offset

[jira] [Updated] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

[ https://issues.apache.org/jira/browse/KAFKA-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mao updated KAFKA-8583: --- Description: The is a propose to optimize SslTransportLayer#write(ByteBuffer). Currently, sslEngine only reads data

[jira] [Updated] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

[ https://issues.apache.org/jira/browse/KAFKA-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mao updated KAFKA-8583: --- Description: The is a propose to optimize SslTransportLayer#write(ByteBuffer). Currently, sslEngine only reads data

[jira] [Commented] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

[ https://issues.apache.org/jira/browse/KAFKA-8583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869908#comment-16869908 ] ASF GitHub Bot commented on KAFKA-8583: --- zzmao commented on pull request #6984: KAFKA-8583:

[jira] [Created] (KAFKA-8583) Optimization for SslTransportLayer#write(ByteBuffer)

Mao created KAFKA-8583: -- Summary: Optimization for SslTransportLayer#write(ByteBuffer) Key: KAFKA-8583 URL: https://issues.apache.org/jira/browse/KAFKA-8583 Project: Kafka Issue Type: Improvement

[jira] [Commented] (KAFKA-8515) Materialize KTable when upstream uses Windowed instead of

[ https://issues.apache.org/jira/browse/KAFKA-8515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869865#comment-16869865 ] ASF GitHub Bot commented on KAFKA-8515: --- abbccdda commented on pull request #6885: KAFKA-8515:

[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869862#comment-16869862 ] Guozhang Wang commented on KAFKA-8106: -- The merged PR is inspired by the original work of #6699 by

[jira] [Updated] (KAFKA-8575) Investigate 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 cleaning up task suspension (part 8) (was: Investigate

[jira] [Created] (KAFKA-8582) Consider adding an ExpiredWindowRecordHandler to Suppress

John Roesler created KAFKA-8582: --- Summary: Consider adding an ExpiredWindowRecordHandler to Suppress Key: KAFKA-8582 URL: https://issues.apache.org/jira/browse/KAFKA-8582 Project: Kafka Issue

[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: Guozhang Wang > Augment ProduceResponse error messaging for specific culprit

[jira] [Updated] (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 updated KAFKA-8581: - Labels: needs-kip user-experience (was: user-experience) > Augment ProduceResponse error

[jira] [Updated] (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 updated KAFKA-8581: - Description: We want to augment the error messaging from broker to producer clients in order to

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

Guozhang Wang created KAFKA-8581: Summary: Augment ProduceResponse error messaging for specific culprit records Key: KAFKA-8581 URL: https://issues.apache.org/jira/browse/KAFKA-8581 Project: Kafka

[jira] [Resolved] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

[ https://issues.apache.org/jira/browse/KAFKA-8106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-8106. -- Resolution: Fixed Fix Version/s: 2.4.0 > Reducing the allocation and copying of

[jira] [Commented] (KAFKA-8106) Reducing the allocation and copying of ByteBuffer when logValidator do validation.

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

[jira] [Commented] (KAFKA-8557) Support named listeners in system tests

[ https://issues.apache.org/jira/browse/KAFKA-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869716#comment-16869716 ] Rajini Sivaram commented on KAFKA-8557: --- Merged [https://github.com/apache/kafka/pull/6938] which

[jira] [Resolved] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

[ https://issues.apache.org/jira/browse/KAFKA-8563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-8563. Resolution: Fixed Fix Version/s: 2.4.0 > Minor: Remove method call in networkSend. Rely on

[jira] [Commented] (KAFKA-8563) Minor: Remove method call in networkSend. Rely on java's vargs boxing/autoboxing

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

[jira] [Commented] (KAFKA-6173) Leader should stop accepting requests when disconnected from ZK

[ https://issues.apache.org/jira/browse/KAFKA-6173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869680#comment-16869680 ] jacky commented on KAFKA-6173: -- Has any plan to fix it? I also think it should, but if the partition only

[jira] [Commented] (KAFKA-8557) Support named listeners in system tests

[ https://issues.apache.org/jira/browse/KAFKA-8557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869679#comment-16869679 ] ASF GitHub Bot commented on KAFKA-8557: --- rajinisivaram commented on pull request #6938: KAFKA-8557:

[jira] [Resolved] (KAFKA-8570) Downconversion could fail when log contains out of order message formats

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

[jira] [Commented] (KAFKA-8570) Downconversion could fail when log contains out of order message formats

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

[jira] [Resolved] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used

[ https://issues.apache.org/jira/browse/KAFKA-6408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Waleed Fateem resolved KAFKA-6408. -- Resolution: Not A Problem > Kafka MirrorMaker doesn't replicate messages when .* regex is used

[jira] [Commented] (KAFKA-8578) Add Functionality to Expose RocksDB Metrics

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

[jira] [Commented] (KAFKA-6408) Kafka MirrorMaker doesn't replicate messages when .* regex is used

[ https://issues.apache.org/jira/browse/KAFKA-6408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869618#comment-16869618 ] Waleed Fateem commented on KAFKA-6408: -- Just closing the loop here. This is only an issue when you

[jira] [Updated] (KAFKA-8578) Add Functionality to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8578: - Summary: Add Functionality to Expose RocksDB Metrics (was: Add Sensors and Metrics to Expose

[jira] [Updated] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8578: - Description: To expose RocksDB metrics as specified in KIP-471, functionality to create and

[jira] [Assigned] (KAFKA-8580) Compute RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8580?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8580: Assignee: Bruno Cadonna > Compute RocksDB Metrics > --- > >

[jira] [Assigned] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8578: Assignee: Bruno Cadonna > Add Sensors and Metrics to Expose RocksDB Metrics >

[jira] [Updated] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8579: - Fix Version/s: 2.4.0 > Expose RocksDB Metrics to JMX > - > >

[jira] [Updated] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8579: - Description: Sensors and the corresponding metrics specified to record RocksDB metrics need to

[jira] [Assigned] (KAFKA-8579) Expose RocksDB Metrics to JMX

[ https://issues.apache.org/jira/browse/KAFKA-8579?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna reassigned KAFKA-8579: Assignee: Bruno Cadonna > Expose RocksDB Metrics to JMX > - >

[jira] [Updated] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8578: - Fix Version/s: 2.4.0 > Add Sensors and Metrics to Expose RocksDB Metrics >

[jira] [Updated] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

[ https://issues.apache.org/jira/browse/KAFKA-8578?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bruno Cadonna updated KAFKA-8578: - Component/s: streams > Add Sensors and Metrics to Expose RocksDB Metrics >

[jira] [Created] (KAFKA-8580) Compute RocksDB Metrics

Bruno Cadonna created KAFKA-8580: Summary: Compute RocksDB Metrics Key: KAFKA-8580 URL: https://issues.apache.org/jira/browse/KAFKA-8580 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8579) Expose RocksDB Metrics to JMX

Bruno Cadonna created KAFKA-8579: Summary: Expose RocksDB Metrics to JMX Key: KAFKA-8579 URL: https://issues.apache.org/jira/browse/KAFKA-8579 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-8519) Trogdor should support network degradation

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

[jira] [Created] (KAFKA-8578) Add Sensors and Metrics to Expose RocksDB Metrics

Bruno Cadonna created KAFKA-8578: Summary: Add Sensors and Metrics to Expose RocksDB Metrics Key: KAFKA-8578 URL: https://issues.apache.org/jira/browse/KAFKA-8578 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-8574) EOS race condition during task transition leads to LocalStateStore truncation in Kafka Streams 2.0.1

[ https://issues.apache.org/jira/browse/KAFKA-8574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869529#comment-16869529 ] William Greer commented on KAFKA-8574: -- This is a different issue from KAFKA-8187. KAFKA-8187 had

[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=16869505#comment-16869505 ] Rajini Sivaram commented on KAFKA-8010: --- [~mimaison] I believe you should be able to use values in

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869352#comment-16869352 ] WooYoung commented on KAFKA-8342: - Not yet. I`m so sorry. I`m going to share some document what I`m

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869349#comment-16869349 ] Carlos Manuel Duclos Vergara commented on KAFKA-8342: - I have read the information in

[jira] [Comment Edited] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869320#comment-16869320 ] WooYoung edited comment on KAFKA-8342 at 6/21/19 9:28 AM: -- yep. It is in

[jira] [Commented] (KAFKA-8342) Admin tool to setup Kafka Stream topology (internal) topics

[ https://issues.apache.org/jira/browse/KAFKA-8342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869320#comment-16869320 ] WooYoung commented on KAFKA-8342: - yep. It is in progress. If I need you help, I would like to be helped

[jira] [Updated] (KAFKA-8576) Consumer failed to join the coordinator

[ https://issues.apache.org/jira/browse/KAFKA-8576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yanrui updated KAFKA-8576: -- Priority: Blocker (was: Critical) > Consumer failed to join the coordinator >

[jira] [Commented] (KAFKA-8544) Remove legacy kafka.admin.AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-8544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869230#comment-16869230 ] ASF GitHub Bot commented on KAFKA-8544: --- ijuma commented on pull request #6947: KAFKA-8544: Remove

[jira] [Updated] (KAFKA-5723) Refactor BrokerApiVersionsCommand to use AdminClient

[ https://issues.apache.org/jira/browse/KAFKA-5723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5723: --- Description: Currently it uses the deprecated AdminClient and in order to remove usages of that

[jira] [Created] (KAFKA-8577) Flaky Test `DistributedHerderTest.testJoinLeaderCatchUpFails`

Jason Gustafson created KAFKA-8577: -- Summary: Flaky Test `DistributedHerderTest.testJoinLeaderCatchUpFails` Key: KAFKA-8577 URL: https://issues.apache.org/jira/browse/KAFKA-8577 Project: Kafka