[jira] [Created] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1

Michael Andre Pearce created KAFKA-5537: --- Summary: Subscribe Earliest is not working as in 0.10.2.1 Key: KAFKA-5537 URL: https://issues.apache.org/jira/browse/KAFKA-5537 Project: Kafka

[jira] [Created] (KAFKA-5536) Tools splitted between Java and Scala implementation

Paolo Patierno created KAFKA-5536: - Summary: Tools splitted between Java and Scala implementation Key: KAFKA-5536 URL: https://issues.apache.org/jira/browse/KAFKA-5536 Project: Kafka Issue Ty

[jira] [Updated] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-5537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Andre Pearce updated KAFKA-5537: Attachment: KafkaSub.java Sorry this is only reporting now post RC vote, we were sti

[jira] [Updated] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-5537?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Michael Andre Pearce updated KAFKA-5537: Description: We have seen issue with subscription where auto offset when set to earl

[jira] [Commented] (KAFKA-5536) Tools splitted between Java and Scala implementation

[ https://issues.apache.org/jira/browse/KAFKA-5536?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16067976#comment-16067976 ] Tom Bentley commented on KAFKA-5536: Isn't it simply that the Kafka core is all writte

[jira] [Commented] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068084#comment-16068084 ] Yuanjia Li commented on KAFKA-5163: --- the ReplicaMoveThread grabs lock on the Replica in

[jira] [Commented] (KAFKA-3114) can't create as many partitions as brokers exists

[ https://issues.apache.org/jira/browse/KAFKA-3114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068120#comment-16068120 ] fengchaoli commented on KAFKA-3114: --- In my case, there were two kafka controllers in my

[jira] [Commented] (KAFKA-5212) Consumer ListOffsets request can starve group heartbeats

[ https://issues.apache.org/jira/browse/KAFKA-5212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068191#comment-16068191 ] Evgeny Veretennikov commented on KAFKA-5212: [~hachikuji], I'd like to work on

[jira] [Created] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

Aegeaner created KAFKA-5538: --- Summary: User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset) Key: KAFKA-5538 URL: https://issues.apache.org/jira/browse/KAFKA-5538

[jira] [Commented] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068205#comment-16068205 ] ASF GitHub Bot commented on KAFKA-5538: --- GitHub user Aegeaner opened a pull request:

[jira] [Updated] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated KAFKA-5538: Affects Version/s: 0.11.0.0 > User-specified Producer/Consumer config doesn't effect with > KafkaBackingSto

[jira] [Updated] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner updated KAFKA-5538: Component/s: KafkaConnect > User-specified Producer/Consumer config doesn't effect with > KafkaBackingStore

[jira] [Resolved] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

[ https://issues.apache.org/jira/browse/KAFKA-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-5402. --- Resolution: Fixed Fix Version/s: 0.11.1.0 Issue resolved by pull request 3303 [https://

[jira] [Commented] (KAFKA-5402) JmxReporter Fetch metrics for kafka.server should not be created when client quotas are not enabled

[ https://issues.apache.org/jira/browse/KAFKA-5402?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068241#comment-16068241 ] ASF GitHub Bot commented on KAFKA-5402: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-5537) Subscribe Earliest is not working as in 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-5537?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068272#comment-16068272 ] Rajini Sivaram commented on KAFKA-5537: --- There is now an initial rebalance delay in

[jira] [Created] (KAFKA-5539) Kafka Connect plugin.path is not used

Diego Montesinos created KAFKA-5539: --- Summary: Kafka Connect plugin.path is not used Key: KAFKA-5539 URL: https://issues.apache.org/jira/browse/KAFKA-5539 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5539) Kafka Connect plugin.path is not used

[ https://issues.apache.org/jira/browse/KAFKA-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Diego Montesinos updated KAFKA-5539: Component/s: KafkaConnect > Kafka Connect plugin.path is not used >

[jira] [Commented] (KAFKA-5539) Kafka Connect plugin.path is not used

[ https://issues.apache.org/jira/browse/KAFKA-5539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068460#comment-16068460 ] Randall Hauch commented on KAFKA-5539: -- What version of Kafka are you using? Hopefull

[jira] [Commented] (KAFKA-3741) KStream config for changelog min.in.sync.replicas

[ https://issues.apache.org/jira/browse/KAFKA-3741?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068489#comment-16068489 ] ASF GitHub Bot commented on KAFKA-3741: --- GitHub user dguy opened a pull request:

[jira] [Assigned] (KAFKA-5538) User-specified Producer/Consumer config doesn't effect with KafkaBackingStore(Config/Status/Offset)

[ https://issues.apache.org/jira/browse/KAFKA-5538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aegeaner reassigned KAFKA-5538: --- Assignee: Aegeaner > User-specified Producer/Consumer config doesn't effect with > KafkaBackingStore

[jira] [Commented] (KAFKA-5515) Consider removing date formatting from Segments class

[ https://issues.apache.org/jira/browse/KAFKA-5515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068546#comment-16068546 ] Neil Avery commented on KAFKA-5515: --- I've taken a look at dropping SimpleDateFormat and

[jira] [Commented] (KAFKA-5484) Refactor kafkatest docker support

[ https://issues.apache.org/jira/browse/KAFKA-5484?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068934#comment-16068934 ] ASF GitHub Bot commented on KAFKA-5484: --- Github user asfgit closed the pull request

[jira] [Commented] (KAFKA-4468) Correctly calculate the window end timestamp after read from state stores

[ https://issues.apache.org/jira/browse/KAFKA-4468?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068935#comment-16068935 ] Matthias J. Sax commented on KAFKA-4468: [~evis] In {{org.apache.kafka.streams.ks

[jira] [Resolved] (KAFKA-5484) Refactor kafkatest docker support

[ https://issues.apache.org/jira/browse/KAFKA-5484?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5484. -- Resolution: Fixed Fix Version/s: 0.11.0.1 0.10.2.2

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068949#comment-16068949 ] Matthias J. Sax commented on KAFKA-5530: [~habdank] Thanks for reporting this. I a

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16068951#comment-16068951 ] Matthias J. Sax commented on KAFKA-5530: Also, Kafka {{0.11.0.0}} was released tod

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

Ewen Cheslack-Postava created KAFKA-5540: Summary: Deprecate and remove internal converter configs Key: KAFKA-5540 URL: https://issues.apache.org/jira/browse/KAFKA-5540 Project: Kafka

[jira] [Created] (KAFKA-5541) Streams should not re-throw if suspending/closing task fails

Matthias J. Sax created KAFKA-5541: -- Summary: Streams should not re-throw if suspending/closing task fails Key: KAFKA-5541 URL: https://issues.apache.org/jira/browse/KAFKA-5541 Project: Kafka

[jira] [Resolved] (KAFKA-5299) MirrorMaker with New.consumer doesn't consume message from multiple topics whitelisted

[ https://issues.apache.org/jira/browse/KAFKA-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Widman resolved KAFKA-5299. Resolution: Cannot Reproduce > MirrorMaker with New.consumer doesn't consume message from multiple t

[jira] [Commented] (KAFKA-5299) MirrorMaker with New.consumer doesn't consume message from multiple topics whitelisted

[ https://issues.apache.org/jira/browse/KAFKA-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069006#comment-16069006 ] Jeff Widman commented on KAFKA-5299: Closing due to lack of activity and inadequate de

[jira] [Commented] (KAFKA-5299) MirrorMaker with New.consumer doesn't consume message from multiple topics whitelisted

[ https://issues.apache.org/jira/browse/KAFKA-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069070#comment-16069070 ] Jyoti commented on KAFKA-5299: -- Hi, I was using the following config : which is not worki

[jira] [Commented] (KAFKA-5163) Support replicas movement between log directories (KIP-113)

[ https://issues.apache.org/jira/browse/KAFKA-5163?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069085#comment-16069085 ] Dong Lin commented on KAFKA-5163: - [~yuanjiali] ReplicaMoveThread will not grab lock for t

[jira] [Commented] (KAFKA-5534) KafkaConsumer offsetsForTimes should include partitions in result even if no offset could be found

[ https://issues.apache.org/jira/browse/KAFKA-5534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069090#comment-16069090 ] ASF GitHub Bot commented on KAFKA-5534: --- GitHub user vahidhashemian opened a pull re

[jira] [Created] (KAFKA-5542) Improve Java doc for LeaderEpochFileCache.endOffsetFor()

Dong Lin created KAFKA-5542: --- Summary: Improve Java doc for LeaderEpochFileCache.endOffsetFor() Key: KAFKA-5542 URL: https://issues.apache.org/jira/browse/KAFKA-5542 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-5542) Improve Java doc for LeaderEpochFileCache.endOffsetFor()

[ https://issues.apache.org/jira/browse/KAFKA-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-5542: Issue Type: Improvement (was: Bug) > Improve Java doc for LeaderEpochFileCache.endOffsetFor() > ---

[jira] [Commented] (KAFKA-5542) Improve Java doc for LeaderEpochFileCache.endOffsetFor()

[ https://issues.apache.org/jira/browse/KAFKA-5542?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069126#comment-16069126 ] Jun Rao commented on KAFKA-5542: We can clarify the following. "During the upgrade phase

[jira] [Created] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker

Apurva Mehta created KAFKA-5543: --- Summary: We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker Key: KAFKA-5543 URL: https://issues.apache.org/jira/browse/KAFKA-5543

[jira] [Commented] (KAFKA-5543) We don't remove the LastStableOffsetLag metric when a partition is moved away from a broker

[ https://issues.apache.org/jira/browse/KAFKA-5543?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069198#comment-16069198 ] ASF GitHub Bot commented on KAFKA-5543: --- GitHub user apurvam opened a pull request:

[jira] [Comment Edited] (KAFKA-5407) Mirrormaker dont start after upgrade

[ https://issues.apache.org/jira/browse/KAFKA-5407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16058639#comment-16058639 ] Fernando Vega edited comment on KAFKA-5407 at 6/30/17 12:54 AM:

[jira] [Created] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

Dong Lin created KAFKA-5544: --- Summary: The LastStableOffsetLag metric should be removed when partition is deleted Key: KAFKA-5544 URL: https://issues.apache.org/jira/browse/KAFKA-5544 Project: Kafka

[jira] [Commented] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

[ https://issues.apache.org/jira/browse/KAFKA-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069406#comment-16069406 ] ASF GitHub Bot commented on KAFKA-5544: --- GitHub user lindong28 opened a pull request

[jira] [Commented] (KAFKA-5153) KAFKA Cluster : 0.10.2.0 : Servers Getting disconnected : Service Impacting

[ https://issues.apache.org/jira/browse/KAFKA-5153?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069411#comment-16069411 ] can_he commented on KAFKA-5153: --- We met the same issue. And I monitored the interface traffi

[jira] [Commented] (KAFKA-5299) MirrorMaker with New.consumer doesn't consume message from multiple topics whitelisted

[ https://issues.apache.org/jira/browse/KAFKA-5299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069438#comment-16069438 ] Jeff Widman commented on KAFKA-5299: The first (non-working) is not a valid regex, or

[jira] [Resolved] (KAFKA-5458) SASL handshake fails for METADATA requests

[ https://issues.apache.org/jira/browse/KAFKA-5458?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sagar Lad resolved KAFKA-5458. -- Resolution: Fixed actually there were multiple consumers created from code - each with different confi

[jira] [Commented] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

[ https://issues.apache.org/jira/browse/KAFKA-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069532#comment-16069532 ] ASF GitHub Bot commented on KAFKA-5544: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

[ https://issues.apache.org/jira/browse/KAFKA-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-5544: --- Fix Version/s: 0.11.1.0 0.11.0.1 > The LastStableOffsetLag metric should be removed

[jira] [Resolved] (KAFKA-5544) The LastStableOffsetLag metric should be removed when partition is deleted

[ https://issues.apache.org/jira/browse/KAFKA-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5544. Resolution: Fixed > The LastStableOffsetLag metric should be removed when partition is deleted > ---

[jira] [Updated] (KAFKA-5535) Transformations - tranformations for value broken on tombstone events

[ https://issues.apache.org/jira/browse/KAFKA-5535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Evgeny Veretennikov updated KAFKA-5535: --- Summary: Transformations - tranformations for value broken on tombstone events (was:

[jira] [Commented] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069595#comment-16069595 ] Seweryn Habdank-Wojewodzki commented on KAFKA-5530: --- Comment to the "all

[jira] [Comment Edited] (KAFKA-5530) Balancer is dancing with KStream all the time, and due to that Kafka cannot work :-)

[ https://issues.apache.org/jira/browse/KAFKA-5530?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16069595#comment-16069595 ] Seweryn Habdank-Wojewodzki edited comment on KAFKA-5530 at 6/30/17 6:44 AM: