[jira] [Created] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level

Coen Damen created KAFKA-6471: - Summary: seekToEnd and seek give unclear results for Consumer with read_committed isolation level Key: KAFKA-6471 URL: https://issues.apache.org/jira/browse/KAFKA-6471 Proj

[jira] [Created] (KAFKA-6472) WordCount example code error

JONYhao created KAFKA-6472: -- Summary: WordCount example code error Key: KAFKA-6472 URL: https://issues.apache.org/jira/browse/KAFKA-6472 Project: Kafka Issue Type: Bug Components: document

[jira] [Updated] (KAFKA-6470) no continuous offset for function seek

[ https://issues.apache.org/jira/browse/KAFKA-6470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] chao.wu updated KAFKA-6470: --- Description: A topic-partition "adn-tracking,15"  in kafka  who's   earliest offset is   1255644602 and  lates

[jira] [Updated] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6472: - Labels: newbie (was: maven) > WordCount example code error > > >

[jira] [Updated] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-6472: - Component/s: streams > WordCount example code error > > >

[jira] [Commented] (KAFKA-6469) ISR change notification queue can prevent controller from making progress

[ https://issues.apache.org/jira/browse/KAFKA-6469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336114#comment-16336114 ] Jeff Widman commented on KAFKA-6469: We hit a similar issue when doing partition re-as

[jira] [Created] (KAFKA-6473) Add MockProcessorContext to public test-utils

Matthias J. Sax created KAFKA-6473: -- Summary: Add MockProcessorContext to public test-utils Key: KAFKA-6473 URL: https://issues.apache.org/jira/browse/KAFKA-6473 Project: Kafka Issue Type: I

[jira] [Created] (KAFKA-6474) Rewrite test to use new public TopologyTestDriver

Matthias J. Sax created KAFKA-6474: -- Summary: Rewrite test to use new public TopologyTestDriver Key: KAFKA-6474 URL: https://issues.apache.org/jira/browse/KAFKA-6474 Project: Kafka Issue Typ

[jira] [Updated] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6472: --- Flags: (was: Important) > WordCount example code error > > >

[jira] [Updated] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6472: --- Priority: Trivial (was: Major) > WordCount example code error >

[jira] [Assigned] (KAFKA-6472) WordCount example code error

[ https://issues.apache.org/jira/browse/KAFKA-6472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax reassigned KAFKA-6472: -- Assignee: Joel Hamill > WordCount example code error > > >

[jira] [Commented] (KAFKA-5660) Don't throw TopologyBuilderException during runtime

[ https://issues.apache.org/jira/browse/KAFKA-5660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336402#comment-16336402 ] Nick Afshartous commented on KAFKA-5660: I'd like to take this as a starter task. 

[jira] [Created] (KAFKA-6475) ConfigException on the broker results in UnknownServerException in the admin client

Xavier Léauté created KAFKA-6475: Summary: ConfigException on the broker results in UnknownServerException in the admin client Key: KAFKA-6475 URL: https://issues.apache.org/jira/browse/KAFKA-6475 Pro

[jira] [Commented] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level

[ https://issues.apache.org/jira/browse/KAFKA-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336483#comment-16336483 ] Jason Gustafson commented on KAFKA-6471: Thanks for reporting the issue. It would

[jira] [Commented] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

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

[jira] [Updated] (KAFKA-3625) Move kafka-streams test fixtures into a published package

[ https://issues.apache.org/jira/browse/KAFKA-3625?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-3625: --- Labels: kip user-experience (was: needs-kip user-experience) > Move kafka-streams test fixtur

[jira] [Updated] (KAFKA-6473) Add MockProcessorContext to public test-utils

[ https://issues.apache.org/jira/browse/KAFKA-6473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-6473: --- Labels: needs-kip user-experience (was: needs-kip) > Add MockProcessorContext to public test-

[jira] [Resolved] (KAFKA-6461) TableTableJoinIntegrationTest is unstable if caching is enabled

[ https://issues.apache.org/jira/browse/KAFKA-6461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-6461. Resolution: Fixed > TableTableJoinIntegrationTest is unstable if caching is enabled > --

[jira] [Created] (KAFKA-6476) Document dynamic config update

Rajini Sivaram created KAFKA-6476: - Summary: Document dynamic config update Key: KAFKA-6476 URL: https://issues.apache.org/jira/browse/KAFKA-6476 Project: Kafka Issue Type: Sub-task

[jira] [Commented] (KAFKA-6243) Enable reconfiguration of metrics reporters and their custom configs

[ https://issues.apache.org/jira/browse/KAFKA-6243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336572#comment-16336572 ] ASF GitHub Bot commented on KAFKA-6243: --- rajinisivaram opened a new pull request #44

[jira] [Commented] (KAFKA-6244) Enable dynamic reconfiguration of log cleaners

[ https://issues.apache.org/jira/browse/KAFKA-6244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336617#comment-16336617 ] ASF GitHub Bot commented on KAFKA-6244: --- rajinisivaram opened a new pull request #44

[jira] [Updated] (KAFKA-6058) Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Widman updated KAFKA-6058: --- Description: {{KafkaAdminClient}} does not allow to get information about consumer groups. This featu

[jira] [Commented] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336639#comment-16336639 ] Jeff Widman commented on KAFKA-6058: Note that listing group offsets has also been add

[jira] [Updated] (KAFKA-6058) KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient

[ https://issues.apache.org/jira/browse/KAFKA-6058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Widman updated KAFKA-6058: --- Summary: KIP-222: Add "describe consumer groups" and "list consumer groups" to KafkaAdminClient (was:

[jira] [Commented] (KAFKA-6245) Enable reconfiguration of default topic configs used by brokers

[ https://issues.apache.org/jira/browse/KAFKA-6245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336652#comment-16336652 ] ASF GitHub Bot commented on KAFKA-6245: --- rajinisivaram opened a new pull request #44

[jira] [Assigned] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Richard Yu reassigned KAFKA-6035: - Assignee: Richard Yu > Avoid creating changelog topics for state stores that are directly piped t

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336667#comment-16336667 ] Richard Yu commented on KAFKA-6035: --- If it is ok, I will be taking this one. Thanks. >

[jira] [Commented] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336798#comment-16336798 ] Richard Yu commented on KAFKA-6035: --- [~guozhang] Currently, I am unsure as to which clas

[jira] [Comment Edited] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

[ https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336798#comment-16336798 ] Richard Yu edited comment on KAFKA-6035 at 1/24/18 2:50 AM: [~

[jira] [Resolved] (KAFKA-6287) Inconsistent protocol type for empty consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-6287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6287. Resolution: Fixed > Inconsistent protocol type for empty consumer groups > -

[jira] [Resolved] (KAFKA-6421) consumer group can't show when use kafka-consumer-groups tool if the leader of __consumer_offsets partition for this group changed

[ https://issues.apache.org/jira/browse/KAFKA-6421?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6421. Resolution: Fixed > consumer group can't show when use kafka-consumer-groups tool if the lea

[jira] [Resolved] (KAFKA-6336) when using assign() with kafka consumer the KafkaConsumerGroup command doesnt show those consumers

[ https://issues.apache.org/jira/browse/KAFKA-6336?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6336. Resolution: Fixed > when using assign() with kafka consumer the KafkaConsumerGroup command d

[jira] [Updated] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledgment

[ https://issues.apache.org/jira/browse/KAFKA-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Litao Deng updated KAFKA-6477: -- Summary: Add Support for Quorum-based Producer Acknowledgment (was: Add Support for Quorum-based Produc

[jira] [Created] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledge

Litao Deng created KAFKA-6477: - Summary: Add Support for Quorum-based Producer Acknowledge Key: KAFKA-6477 URL: https://issues.apache.org/jira/browse/KAFKA-6477 Project: Kafka Issue Type: New Fea

[jira] [Updated] (KAFKA-6477) Add Support for Quorum-based Producer Acknowledgment

[ https://issues.apache.org/jira/browse/KAFKA-6477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Litao Deng updated KAFKA-6477: -- Description: Hey folks. I would like to add a feature to support the quorum-based acknowledgment for th

[jira] [Commented] (KAFKA-5540) Deprecate and remove internal converter configs

[ https://issues.apache.org/jira/browse/KAFKA-5540?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336964#comment-16336964 ] ASF GitHub Bot commented on KAFKA-5540: --- umesh9794 opened a new pull request #4467:

[jira] [Commented] (KAFKA-6468) Replication high watermark checkpoint file read for every LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-6468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16336969#comment-16336969 ] ASF GitHub Bot commented on KAFKA-6468: --- ambroff opened a new pull request #4468: KA

[jira] [Commented] (KAFKA-5142) KIP-145 - Expose Record Headers in Kafka Connect

[ https://issues.apache.org/jira/browse/KAFKA-5142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337069#comment-16337069 ] Randall Hauch commented on KAFKA-5142: -- KIP-145 has passed. > KIP-145 - Expose Recor

[jira] [Commented] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level

[ https://issues.apache.org/jira/browse/KAFKA-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337075#comment-16337075 ] Coen Damen commented on KAFKA-6471: --- Hi Jason, thanks for your reply. The Use Case is t

[jira] [Comment Edited] (KAFKA-6471) seekToEnd and seek give unclear results for Consumer with read_committed isolation level

[ https://issues.apache.org/jira/browse/KAFKA-6471?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16337075#comment-16337075 ] Coen Damen edited comment on KAFKA-6471 at 1/24/18 7:40 AM: Hi