[jira] [Comment Edited] (KAFKA-6678) Upgrade dependencies with later release versions

[ https://issues.apache.org/jira/browse/KAFKA-6678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16434768#comment-16434768 ] Ted Yu edited comment on KAFKA-6678 at 4/19/18 4:47 AM: Looks like 2.0 release in

[jira] [Commented] (KAFKA-6730) Simplify state store recovery

[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443565#comment-16443565 ] Richard Yu commented on KAFKA-6730: --- [~mjsax] If possible, could I take this JIRA? > Simplify state

[jira] [Commented] (KAFKA-6730) Simplify state store recovery

[ https://issues.apache.org/jira/browse/KAFKA-6730?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443524#comment-16443524 ] Richard Yu commented on KAFKA-6730: --- In the new code, would StoreChangeLogReader#restorePartition be

[jira] [Commented] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

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

[jira] [Resolved] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-6775. -- Resolution: Fixed Fix Version/s: 1.2.0 > AbstractProcessor created in SimpleBenchmark

[jira] [Commented] (KAFKA-6775) AbstractProcessor created in SimpleBenchmark should call super#init

[ https://issues.apache.org/jira/browse/KAFKA-6775?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443259#comment-16443259 ] ASF GitHub Bot commented on KAFKA-6775: --- guozhangwang closed pull request #4859: KAFKA-6775: Fix the

[jira] [Created] (KAFKA-6803) Caching is turned off for stream-stream Join

Guozhang Wang created KAFKA-6803: Summary: Caching is turned off for stream-stream Join Key: KAFKA-6803 URL: https://issues.apache.org/jira/browse/KAFKA-6803 Project: Kafka Issue Type:

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443182#comment-16443182 ] Ismael Juma commented on KAFKA-3042: [~junrao], is this fixed in 1.1.0? > updateIsr should stop after

[jira] [Reopened] (KAFKA-2334) Prevent HW from going back during leader failover

[ https://issues.apache.org/jira/browse/KAFKA-2334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma reopened KAFKA-2334: > Prevent HW from going back during leader failover >

[jira] [Comment Edited] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only)

[ https://issues.apache.org/jira/browse/KAFKA-6406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443083#comment-16443083 ] Kevin Vasko edited comment on KAFKA-6406 at 4/18/18 7:41 PM: - I get this same

[jira] [Comment Edited] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only)

[ https://issues.apache.org/jira/browse/KAFKA-6406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443083#comment-16443083 ] Kevin Vasko edited comment on KAFKA-6406 at 4/18/18 7:41 PM: - I get this same

[jira] [Commented] (KAFKA-6406) Topic deletion fails and kafka shuts down (on windows only)

[ https://issues.apache.org/jira/browse/KAFKA-6406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443083#comment-16443083 ] Kevin Vasko commented on KAFKA-6406: I get this same error message. I am on windows 10 and Kafka

[jira] [Updated] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

[ https://issues.apache.org/jira/browse/KAFKA-6802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6802: --- Component/s: streams > Improve logging when topics aren't known and assignments skipped >

[jira] [Updated] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

[ https://issues.apache.org/jira/browse/KAFKA-6802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck updated KAFKA-6802: --- Fix Version/s: 1.2.0 > Improve logging when topics aren't known and assignments skipped >

[jira] [Commented] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

[ https://issues.apache.org/jira/browse/KAFKA-6802?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16443022#comment-16443022 ] ASF GitHub Bot commented on KAFKA-6802: --- bbejeck opened a new pull request #4891: KAFKA-6802:

[jira] [Created] (KAFKA-6802) Improve logging when topics aren't known and assignments skipped

Bill Bejeck created KAFKA-6802: -- Summary: Improve logging when topics aren't known and assignments skipped Key: KAFKA-6802 URL: https://issues.apache.org/jira/browse/KAFKA-6802 Project: Kafka

[jira] [Comment Edited] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442941#comment-16442941 ] Riley Zimmerman edited comment on KAFKA-6798 at 4/18/18 5:46 PM: - Around

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442941#comment-16442941 ] Riley Zimmerman commented on KAFKA-6798: Around once a minute I see this, otherwise nothing bad in

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442861#comment-16442861 ] Manikumar commented on KAFKA-6798: -- Yes, rebalances are due to zookeeper disconnects. Since it is

[jira] [Commented] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442773#comment-16442773 ] ASF GitHub Bot commented on KAFKA-3365: --- hachikuji closed pull request #4735: KAFKA-3365 Add a

[jira] [Resolved] (KAFKA-3365) Add a documentation field for types and update doc generation

[ https://issues.apache.org/jira/browse/KAFKA-3365?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-3365. Resolution: Fixed > Add a documentation field for types and update doc generation >

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442765#comment-16442765 ] Riley Zimmerman commented on KAFKA-6798: Looking at the verbosegc, I do see large mark/sweeps

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442683#comment-16442683 ] Riley Zimmerman commented on KAFKA-6798: I was just about to post that I saw you recommend 30s

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442656#comment-16442656 ] Manikumar commented on KAFKA-6798: -- It does look like zk session timeout issue. Not sure why happening

[jira] [Created] (KAFKA-6801) Restrict Consumer to fetch data from secure port only, and deny from non-secure port.

VinayKumar created KAFKA-6801: - Summary: Restrict Consumer to fetch data from secure port only, and deny from non-secure port. Key: KAFKA-6801 URL: https://issues.apache.org/jira/browse/KAFKA-6801

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442546#comment-16442546 ] Riley Zimmerman commented on KAFKA-6798: I have setup a script monitoring the liveness and

[jira] [Commented] (KAFKA-5830) kafka-configs.sh should allow deletion of all configs for an entity

[ https://issues.apache.org/jira/browse/KAFKA-5830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442491#comment-16442491 ] ASF GitHub Bot commented on KAFKA-5830: --- mimaison closed pull request #3785: KAFKA-5830:

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442490#comment-16442490 ] Manikumar commented on KAFKA-6335: -- [~Sonia] Can you give more details? Are you seeing test failure or an

[jira] [Commented] (KAFKA-5483) Shutdown of scheduler should come after LogManager

[ https://issues.apache.org/jira/browse/KAFKA-5483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442485#comment-16442485 ] ASF GitHub Bot commented on KAFKA-5483: --- mimaison closed pull request #3452: KAFKA-5483: Shutdown of

[jira] [Commented] (KAFKA-6800) Update documentation for SASL/PLAIN and SCRAM to use callbacks

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

[jira] [Commented] (KAFKA-6335) SimpleAclAuthorizerTest#testHighConcurrencyModificationOfResourceAcls fails intermittently

[ https://issues.apache.org/jira/browse/KAFKA-6335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442400#comment-16442400 ] Sonia Garudi commented on KAFKA-6335: - Hi, I encountered the same error. Is there any update on this?

[jira] [Commented] (KAFKA-5813) Unexpected unclean leader election due to leader/controller's unusual event handling order

[ https://issues.apache.org/jira/browse/KAFKA-5813?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442343#comment-16442343 ] Manikumar commented on KAFKA-5813: -- This might have fixed in async zk controller changes. > Unexpected

[jira] [Created] (KAFKA-6800) Update documentation for SASL/PLAIN and SCRAM to use callbacks

Rajini Sivaram created KAFKA-6800: - Summary: Update documentation for SASL/PLAIN and SCRAM to use callbacks Key: KAFKA-6800 URL: https://issues.apache.org/jira/browse/KAFKA-6800 Project: Kafka

[jira] [Resolved] (KAFKA-1716) hang during shutdown of ZookeeperConsumerConnector

[ https://issues.apache.org/jira/browse/KAFKA-1716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1716. -- Resolution: Auto Closed Closing inactive issue. The Scala consumers have been deprecated and no further

[jira] [Resolved] (KAFKA-5287) Messages getting repeated in kafka

[ https://issues.apache.org/jira/browse/KAFKA-5287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5287. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think the

[jira] [Resolved] (KAFKA-6772) Broker should load credentials from ZK before requests are allowed

[ https://issues.apache.org/jira/browse/KAFKA-6772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6772. --- Resolution: Fixed Reviewer: Jun Rao > Broker should load credentials from ZK before

[jira] [Resolved] (KAFKA-5262) Can't find some consumer group information

[ https://issues.apache.org/jira/browse/KAFKA-5262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-5262. -- Resolution: Cannot Reproduce Closing inactive issue. Please reopen with more details., if you think the

[jira] [Resolved] (KAFKA-3476) -Xloggc is not recognised by IBM java

[ https://issues.apache.org/jira/browse/KAFKA-3476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3476. -- Resolution: Won't Fix Closing this as we can export the GC values and performance opts. Please reopen

[jira] [Commented] (KAFKA-6772) Broker should load credentials from ZK before requests are allowed

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

[jira] [Commented] (KAFKA-5413) Log cleaner fails due to large offset in segment file

[ https://issues.apache.org/jira/browse/KAFKA-5413?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442121#comment-16442121 ] David Lopez commented on KAFKA-5413: Hi, I have the same problem and I'm running 0.11.0.2. That is

[jira] [Commented] (KAFKA-6054) ERROR "SubscriptionInfo - unable to decode subscription data: version=2" when upgrading from 0.10.0.0 to 0.10.2.1

[ https://issues.apache.org/jira/browse/KAFKA-6054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442058#comment-16442058 ] ASF GitHub Bot commented on KAFKA-6054: --- mjsax closed pull request #4880: KAFKA-6054: Update Kafka

[jira] [Resolved] (KAFKA-6107) SCRAM user add appears to fail if Kafka has never been started

[ https://issues.apache.org/jira/browse/KAFKA-6107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-6107. -- Resolution: Fixed Fix Version/s: 1.1.0 This was fixed in KafkaZkClient changes work. > SCRAM

[jira] [Commented] (KAFKA-6555) Making state store queryable during restoration

[ https://issues.apache.org/jira/browse/KAFKA-6555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16442006#comment-16442006 ] Michael Noll commented on KAFKA-6555: - Any updates here [~asurana]? > Making state store queryable

[jira] [Commented] (KAFKA-1194) The kafka broker cannot delete the old log files after the configured time

[ https://issues.apache.org/jira/browse/KAFKA-1194?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441993#comment-16441993 ] Christoph Schmidt commented on KAFKA-1194: -- Seeing this in a project which is supposed to

[jira] [Comment Edited] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441972#comment-16441972 ] Manikumar edited comment on KAFKA-6798 at 4/18/18 6:43 AM: --- ISR is set to empty

[jira] [Commented] (KAFKA-6798) Kafka leader rebalance failures

[ https://issues.apache.org/jira/browse/KAFKA-6798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16441972#comment-16441972 ] Manikumar commented on KAFKA-6798: -- ISR is set to empty if all replicas are out of sync and unclean