[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-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&focusedCommentId=16869320#comment-16869320 ] WooYoung commented on KAFKA-8342: - yep. It is in progress. If I need you help, I would l

[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&focusedCommentId=16869320#comment-16869320 ] WooYoung edited comment on KAFKA-8342 at 6/21/19 9:28 AM: -- yep.

[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&focusedCommentId=16869349#comment-16869349 ] Carlos Manuel Duclos Vergara commented on KAFKA-8342: - I have read th

[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&focusedCommentId=16869352#comment-16869352 ] WooYoung commented on KAFKA-8342: - Not yet. I`m so sorry. I`m going to share some docume

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

[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&focusedCommentId=16869529#comment-16869529 ] William Greer commented on KAFKA-8574: -- This is a different issue from KAFKA-8187. K

[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: S

[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&focusedCommentId=16869588#comment-16869588 ] ASF GitHub Bot commented on KAFKA-8519: --- mumrah commented on pull request #6912: KA

[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 Co

[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 Componen

[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] [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 be

[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] [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] [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] [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 recor

[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 Roc

[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&focusedCommentId=16869618#comment-16869618 ] Waleed Fateem commented on KAFKA-6408: -- Just closing the loop here. This is only an

[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&focusedCommentId=16869620#comment-16869620 ] ASF GitHub Bot commented on KAFKA-8578: --- cadonna commented on pull request #6979: K

[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-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&focusedCommentId=16869657#comment-16869657 ] ASF GitHub Bot commented on KAFKA-8570: --- hachikuji commented on pull request #6974:

[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 2.

[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&focusedCommentId=16869679#comment-16869679 ] ASF GitHub Bot commented on KAFKA-8557: --- rajinisivaram commented on pull request #6

[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&focusedCommentId=16869680#comment-16869680 ] jacky commented on KAFKA-6173: -- Has any plan to fix it? I also think it should, but if the p

[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&focusedCommentId=16869684#comment-16869684 ] ASF GitHub Bot commented on KAFKA-8563: --- ijuma commented on pull request #6967: KAF

[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 j

[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&focusedCommentId=16869716#comment-16869716 ] Rajini Sivaram commented on KAFKA-8557: --- Merged [https://github.com/apache/kafka/pu

[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&focusedCommentId=16869836#comment-16869836 ] ASF GitHub Bot commented on KAFKA-8106: --- guozhangwang commented on pull request #67

[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 ByteBuff

[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] [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 l

[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 rec

[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 messagi

[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 T

[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 cleaning

[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&focusedCommentId=16869862#comment-16869862 ] Guozhang Wang commented on KAFKA-8106: -- The merged PR is inspired by the original wo

[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&focusedCommentId=16869865#comment-16869865 ] ASF GitHub Bot commented on KAFKA-8515: --- abbccdda commented on pull request #6885:

[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] [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&focusedCommentId=16869908#comment-16869908 ] ASF GitHub Bot commented on KAFKA-8583: --- zzmao commented on pull request #6984: KAF

[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-7500) MirrorMaker 2.0 (KIP-382)

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

[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] [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 chec

[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&focusedCommentId=16869529#comment-16869529 ] William Greer edited comment on KAFKA-8574 at 6/21/19 11:13 PM: ---

[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] [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 b

[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&focusedCommentId=16869968#comment-16869968 ] SuryaTeja Duggi commented on KAFKA-8584: Let me know if there is any thing else t

[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] [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 Type:

[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&focusedCommentId=16870022#comment-16870022 ] yanrui commented on KAFKA-8576: --- 2019-05-27 15:16:09 860 INFO [org.apache.kafka.clients.c

[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&focusedCommentId=16870039#comment-16870039 ] yanrui edited comment on KAFKA-8576 at 6/22/19 3:56 AM: Is it pos

[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&focusedCommentId=16870039#comment-16870039 ] yanrui commented on KAFKA-8576: --- Is it possible that the leaderAndIsr sent by the controll

[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&focusedCommentId=16870040#comment-16870040 ] yanrui commented on KAFKA-8576: --- The problem is solved after the broker restarts. > Consum

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

[ https://issues.apache.org/jira/browse/KAFKA-8582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-8582: --- Component/s: streams > Consider adding an ExpiredWindowRecordHandler to Suppress > --