[jira] [Comment Edited] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747454#comment-15747454 ] Roger Hoover edited comment on KAFKA-4166 at 12/14/16 6:37 AM: --- It happened

[jira] [Comment Edited] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747454#comment-15747454 ] Roger Hoover edited comment on KAFKA-4166 at 12/14/16 6:36 AM: --- It happened

[jira] [Commented] (KAFKA-4166) TestMirrorMakerService.test_bounce transient system test failure

[ https://issues.apache.org/jira/browse/KAFKA-4166?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747454#comment-15747454 ] Roger Hoover commented on KAFKA-4166: - It happened twice more on these test: {code} "Module:

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747403#comment-15747403 ] Manikumar Reddy commented on KAFKA-1696: [~singhashish] Yes, Pl go ahead and create sub-jiras and

Re: [DISCUSS] KIP-98: Exactly Once Delivery and Transactional Messaging

Hi Apurva, Thanks for the detailed answers... and sorry for the late reply! It does sound like, if the input-partitions-to-app-id mapping never changes, the existing fencing mechanisms should prevent duplicates. Great! I'm a bit concerned the proposed API will be delicate to program against

[jira] [Commented] (KAFKA-4526) Transient failure in ThrottlingTest.test_throttled_reassignment

[ https://issues.apache.org/jira/browse/KAFKA-4526?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747308#comment-15747308 ] Roger Hoover commented on KAFKA-4526: - This happened again on the Dec 13 nightly run. > Transient

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747271#comment-15747271 ] Michael Andre Pearce (IG) edited comment on KAFKA-4477 at 12/14/16 4:59 AM:

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747271#comment-15747271 ] Michael Andre Pearce (IG) edited comment on KAFKA-4477 at 12/14/16 4:58 AM:

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747271#comment-15747271 ] Michael Andre Pearce (IG) edited comment on KAFKA-4477 at 12/14/16 4:55 AM:

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15747271#comment-15747271 ] Michael Andre Pearce (IG) commented on KAFKA-4477: -- Hi Apurva, Whilst i await the issue

Build failed in Jenkins: kafka-trunk-jdk8 #1102

See Changes: [wangguoz] Separate Streams documentation and setup docs with easy to set variables -- [...truncated 17356 lines...] org.apache.kafka.streams.KafkaStreamsTest >

Re: [DISCUSS] KIP-48 Support for delegation tokens as an authentication mechanism

Thinking out loud here: It looks like authentication with a delegation token is going to be super-cheap, right? We just compare the token to a value in the broker cache? If I understood the KIP correctly, right now it suggests that authentication happens when establishing the client-broker

Re: [DISCUSS] KIP-90 Remove zkClient dependency from Streams

Makes sense :) On Tue, Dec 13, 2016 at 5:50 PM Jay Kreps wrote: > Ha, least controversial KIP ever. :-) > > -Jay > > On Tue, Dec 13, 2016 at 10:39 AM, Hojjat Jafarpour > wrote: > > > Hi all, > > > > The following is a KIP for removing zkClient dependency

Re: Website Update, Part 2

Hi, Since we are breaking down the docs, we can no longer use ctrl-f to find where to find specific things we are looking for... maybe it is time to add a site search bar? I think google has something we can embed. On Tue, Dec 13, 2016 at 6:12 PM, Guozhang Wang wrote: >

Website Update, Part 2

Folks, We are continuing to improve our website, and one of it is to break the single gigantic "documentation" page: https://kafka.apache.org/documentation/ into sub-spaces and sub-pages for better visibility. As the first step of this effort, we will be gradually extract each section of this

Re: [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams

Avi, thanks for your feedback. We want to enlarge the scope for Streams application and started to collect use cases in the Wiki: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Streams+Data+%28Re%29Processing+Scenarios Feel free to add there via editing the page or writing a comment.

[GitHub] kafka pull request #2245: Separate Streams documentation and setup docs with...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2245 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Re: [DISCUSS] KIP-82 - Add Record Headers

Hi, I want to add a completely new angle to this discussion. For this, I want to propose an extension for the headers feature that enables new uses cases -- and those new use cases might convince people to support headers (of course including the larger scoped proposal). Extended Proposal:

[jira] [Commented] (KAFKA-4505) Cannot get topic lag since kafka upgrade from 0.8.1.0 to 0.10.1.0

[ https://issues.apache.org/jira/browse/KAFKA-4505?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746918#comment-15746918 ] huxi commented on KAFKA-4505: - I don't think it's a good solution. The path you created in Zookeeper should

[GitHub] kafka-site issue #17: Update quickstart guides with a note to refer to the c...

Github user gwenshap commented on the issue: https://github.com/apache/kafka-site/pull/17 This PR is slightly older and I think we added the warning while re-working the site based on this PR (Thanks @cptcanuck!). I think it can be closed? --- If your project is set up for it,

Re: [DISCUSS] KIP-90 Remove zkClient dependency from Streams

Ha, least controversial KIP ever. :-) -Jay On Tue, Dec 13, 2016 at 10:39 AM, Hojjat Jafarpour wrote: > Hi all, > > The following is a KIP for removing zkClient dependency from Streams. > Please check out the KIP page: > >

[jira] [Commented] (KAFKA-1696) Kafka should be able to generate Hadoop delegation tokens

[ https://issues.apache.org/jira/browse/KAFKA-1696?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746886#comment-15746886 ] Ashish K Singh commented on KAFKA-1696: --- [~omkreddy] as I indicated on discuss list, I have made

[GitHub] kafka-site issue #36: Streams standalone docs

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/36 Merged, thanks! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes

[GitHub] kafka-site pull request #36: Streams standalone docs

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/36 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-4030) Update older quickstart documents to clarify which version they relate to

[ https://issues.apache.org/jira/browse/KAFKA-4030?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746872#comment-15746872 ] ASF GitHub Bot commented on KAFKA-4030: --- Github user guozhangwang commented on the issue:

[GitHub] kafka-site issue #17: Update quickstart guides with a note to refer to the c...

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/17 @cptcanuck Could you rebase this PR then I will merge as is? Thanks. Also could you update the PR title as ``` KAFKA-4030: Update ``` since it will be used as

[GitHub] kafka-site issue #37: Add new meetup link on events page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/37 Already reflected on the web site: https://kafka.apache.org/events cheers. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If

[GitHub] kafka-site pull request #37: Add new meetup link on events page

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/37 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka-site issue #37: Add new meetup link on events page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/37 Great to hear about meetup in Japan! Merged this PR. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not

[GitHub] kafka-site issue #34: Fix typo on introduction page

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/34 Thanks @ashishg-qburst , could you file the PR against kafka repo itself on this file: https://github.com/apache/kafka/blob/trunk/docs/introduction.html Since it will be copied to

[GitHub] kafka-site issue #33: Update contact.html

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/33 Thanks @dossett , merged. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled

[GitHub] kafka-site pull request #33: Update contact.html

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/33 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka-site issue #23: Grammar updated

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/23 Thanks @muehlburger , merged. --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature

[GitHub] kafka-site pull request #23: Grammar updated

Github user asfgit closed the pull request at: https://github.com/apache/kafka-site/pull/23 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka-site issue #18: Implementation: Clean-up invalid HTML

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/18 Thanks @epeay , could you file the PR against https://github.com/apache/kafka/blob/trunk/docs/implementation.html instead since we will periodically move the docs when doing the release.

[jira] [Commented] (KAFKA-3869) Fix streams example

[ https://issues.apache.org/jira/browse/KAFKA-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746808#comment-15746808 ] ASF GitHub Bot commented on KAFKA-3869: --- Github user sakamotomsh closed the pull request at:

[GitHub] kafka pull request #1524: KAFKA-3869 Fix streams example

Github user sakamotomsh closed the pull request at: https://github.com/apache/kafka/pull/1524 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature

[jira] [Closed] (KAFKA-3869) Fix streams example

[ https://issues.apache.org/jira/browse/KAFKA-3869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Masahiko Sakamoto closed KAFKA-3869. > Fix streams example > --- > > Key: KAFKA-3869 >

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746799#comment-15746799 ] Apurva Mehta commented on KAFKA-4477: - [~tdevoe], thanks for sharing all your extend broker logs, as

Kafka ACL's with SSL Protocol is not working

Hi All, I am trying to enable ACL's in my Kafka cluster with along with SSL Protocol. I tried with each and every parameters but no luck, so I need help to enable the SSL(without Kerberos) and I am attaching all the configuration details in this. Kindly Help me. *I tested SSL without ACL, it

Re: [DISCUSS] KIP-95: Incremental Batch Processing for Kafka Streams

On 2016-11-28 13:47 (-0500), "Matthias J. Sax" wrote: > > I want to start a discussion about KIP-95: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-95%3A+Incremental+Batch+Processing+for+Kafka+Streams > > Looking forward to your feedback. Hi Matthias, I’d just

Jenkins build is back to normal : kafka-trunk-jdk8 #1101

See

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746479#comment-15746479 ] Lorand Peter Kasler commented on KAFKA-4477: Yes, we recently upgraded and started getting

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746466#comment-15746466 ] Ismael Juma commented on KAFKA-4477: One question for the others that have reported this issue: have

Jenkins build is back to normal : kafka-trunk-jdk7 #1753

See

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746402#comment-15746402 ] Tom DeVoe commented on KAFKA-4477: -- I was able to telnet from the controller node to the kafka port on

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746403#comment-15746403 ] Tom DeVoe commented on KAFKA-4477: -- I was able to telnet from the controller node to the kafka port on

[jira] [Issue Comment Deleted] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom DeVoe updated KAFKA-4477: - Comment: was deleted (was: I was able to telnet from the controller node to the kafka port on node 1002

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746393#comment-15746393 ] Jun Rao commented on KAFKA-4477: [~tdevoe], from the controller log, starting from 19:59:13, the

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746368#comment-15746368 ] Lorand Peter Kasler commented on KAFKA-4477: We had encountered the same situation (even

Re: [DISCUSS] KIP-90 Remove zkClient dependency from Streams

Thanks for the KIP, Hojjat. It will be great for Streams apps not to require ZK access. Ismael On Tue, Dec 13, 2016 at 10:39 AM, Hojjat Jafarpour wrote: > Hi all, > > The following is a KIP for removing zkClient dependency from Streams. > Please check out the KIP page: > >

Re: [DISCUSS] KIP-90 Remove zkClient dependency from Streams

Great idea, go for it :) On Tue, Dec 13, 2016 at 10:39 AM, Hojjat Jafarpour wrote: > Hi all, > > The following is a KIP for removing zkClient dependency from Streams. > Please check out the KIP page: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP- >

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15746249#comment-15746249 ] ASF GitHub Bot commented on KAFKA-4497: --- Github user becketqin closed the pull request at:

[GitHub] kafka pull request #2242: KAFKA-4497: Fix the ByteBufferMessageSet.filterInt...

Github user becketqin closed the pull request at: https://github.com/apache/kafka/pull/2242 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

Build failed in Jenkins: kafka-trunk-jdk7 #1752

See Changes: [wangguoz] MINOR: Fix Streams examples in documentation -- [...truncated 6277 lines...] kafka.api.PlaintextProducerSendTest > testSendOffset STARTED

[GitHub] kafka pull request #2252: HOTFIX: fix state transition stuck on rebalance

GitHub user enothereska opened a pull request: https://github.com/apache/kafka/pull/2252 HOTFIX: fix state transition stuck on rebalance This fixes a problem where the Kafka instance state transition gets stuck on rebalance. Also adjusts the test in QueryableStateIntegration test.

Build failed in Jenkins: kafka-trunk-jdk8 #1100

See Changes: [jason] KAFKA-4390; Replace MessageSet usage with client-side alternatives -- [...truncated 7920 lines...] kafka.utils.timer.TimerTaskListTest > testAll STARTED

[jira] [Commented] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

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

[GitHub] kafka pull request #2250: KAFKA-4532: StateStores can be connected to the wr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2250 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4532. -- Resolution: Fixed Issue resolved by pull request 2250

[jira] [Commented] (KAFKA-4509) Task reusage on rebalance fails for threads on same host

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

[GitHub] kafka pull request #2233: KAFKA-4509: Task reusage on rebalance fails for th...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2233 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Updated] (KAFKA-4509) Task reusage on rebalance fails for threads on same host

[ https://issues.apache.org/jira/browse/KAFKA-4509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4509: - Resolution: Fixed Fix Version/s: 0.10.2.0 Status: Resolved (was: Patch

[jira] [Created] (KAFKA-4534) StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once.

Damian Guy created KAFKA-4534: - Summary: StreamPartitionAssignor only ever updates the partitionsByHostState and metadataWithInternalTopics once. Key: KAFKA-4534 URL: https://issues.apache.org/jira/browse/KAFKA-4534

[jira] [Commented] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745978#comment-15745978 ] Avi Flax commented on KAFKA-4437: - Ah, great, thanks! > Incremental Batch Processing for Kafka Streams >

Build failed in Jenkins: kafka-trunk-jdk8 #1099

See Changes: [wangguoz] MINOR: Fix Streams examples in documentation -- [...truncated 3907 lines...] kafka.utils.CommandLineUtilsTest > testParseEmptyArg STARTED

[jira] [Commented] (KAFKA-4529) tombstone may be removed earlier than it should

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

[GitHub] kafka pull request #2251: KAFKA-4529; Fix the issue that tombstone can be de...

GitHub user becketqin opened a pull request: https://github.com/apache/kafka/pull/2251 KAFKA-4529; Fix the issue that tombstone can be deleted too early. You can merge this pull request into a Git repository by running: $ git pull https://github.com/becketqin/kafka KAFKA-4529

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745919#comment-15745919 ] Tom DeVoe commented on KAFKA-4477: -- Sorry about that [~apurva], I attached the state change and

[jira] [Updated] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tom DeVoe updated KAFKA-4477: - Attachment: state_change_controller.tar.gz > Node reduces its ISR to itself, and doesn't recover. Other

[jira] [Commented] (KAFKA-4390) Replace MessageSet usage with client-side equivalents

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

[GitHub] kafka pull request #2140: KAFKA-4390: Replace MessageSet usage with client-s...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2140 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Resolved] (KAFKA-4390) Replace MessageSet usage with client-side equivalents

[ https://issues.apache.org/jira/browse/KAFKA-4390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-4390. Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2140

[DISCUSS] KIP-90 Remove zkClient dependency from Streams

Hi all, The following is a KIP for removing zkClient dependency from Streams. Please check out the KIP page: https://cwiki.apache.org/confluence/display/KAFKA/KIP-90+-+Remove+zkClient+dependency+from+Streams Thanks, --Hojjat

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745817#comment-15745817 ] Jun Rao commented on KAFKA-4477: [~michael.andre.pearce], [~tdevoe], was the following exception in the

[jira] [Commented] (KAFKA-4269) Multiple KStream instances with at least one Regex source causes NPE when using multiple consumers

[ https://issues.apache.org/jira/browse/KAFKA-4269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745818#comment-15745818 ] ASF GitHub Bot commented on KAFKA-4269: --- Github user bbejeck closed the pull request at:

[GitHub] kafka pull request #2090: KAFKA-4269: Follow up for 0.10.1 branch -update to...

Github user bbejeck closed the pull request at: https://github.com/apache/kafka/pull/2090 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745813#comment-15745813 ] Jun Rao commented on KAFKA-4477: [~tdevoe], thanks for the clarification. Then, it looks similar to what's

[jira] [Commented] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

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

[GitHub] kafka pull request #2250: KAFKA-4532: StateStores can be connected to the wr...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2250 KAFKA-4532: StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from Interactive Queries When building a topology with tables and StateStores, the

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745782#comment-15745782 ] Jun Rao commented on KAFKA-4477: [~michael.andre.pearce], the 0.10.1.1 release will need RC1 since we need

[jira] [Updated] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4532: -- Description: When building a topology with tables and StateStores, the StateStores are mapped to the

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745749#comment-15745749 ] Michael Andre Pearce (IG) edited comment on KAFKA-4477 at 12/13/16 5:49 PM:

Re: Dev list subscribe

Sorry, that was a mail sent by mistake. On Tue, Dec 13, 2016 at 5:39 PM, Guozhang Wang wrote: > Rajini, > > It's self-service :) > > https://kafka.apache.org/contact > > Guozhang > > On Tue, Dec 13, 2016 at 5:38 AM, Rajini Sivaram > wrote: > > > Please

[jira] [Resolved] (KAFKA-4497) log cleaner breaks on timeindex

[ https://issues.apache.org/jira/browse/KAFKA-4497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-4497. Resolution: Fixed [~roschumann], I merged Jiangjie's batch to 0.10.1 branch. Do you think you could give

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745749#comment-15745749 ] Michael Andre Pearce (IG) commented on KAFKA-4477: -- It is worth noting we see the open

[jira] [Commented] (KAFKA-4497) log cleaner breaks on timeindex

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

[GitHub] kafka pull request #2243: KAFKA-4497: LogCleaner appended the wrong offset t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2243 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[GitHub] kafka pull request #2247: MINOR: Fix Streams examples in documentation

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2247 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745734#comment-15745734 ] Michael Andre Pearce (IG) commented on KAFKA-4477: -- Hi Jun, The stack was taken by the

Re: Dev list subscribe

Rajini, It's self-service :) https://kafka.apache.org/contact Guozhang On Tue, Dec 13, 2016 at 5:38 AM, Rajini Sivaram wrote: > Please subscribe me to the Kafka dev list. > > > Thank you, > > Rajini > -- -- Guozhang

Re: [DISCUSS] KIP-81: Max in-flight fetches

Coordinator starvation: For an implementation based on KIP-72, there will be coordinator starvation without KAFKA-4137 since you would stop reading from sockets when the memory pool is full (the fact that coordinator messages are small doesn't help). I imagine you can work around this by treating

[jira] [Commented] (KAFKA-4437) Incremental Batch Processing for Kafka Streams

[ https://issues.apache.org/jira/browse/KAFKA-4437?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745672#comment-15745672 ] Matthias J. Sax commented on KAFKA-4437: There is a mailing list thread... Just forgot to update

[jira] [Commented] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745663#comment-15745663 ] Tom DeVoe commented on KAFKA-4477: -- [~junrao] I respectfully disagree, and this is why I originally was

[jira] [Comment Edited] (KAFKA-4477) Node reduces its ISR to itself, and doesn't recover. Other nodes do not take leadership, cluster remains sick until node is restarted.

[ https://issues.apache.org/jira/browse/KAFKA-4477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15745663#comment-15745663 ] Tom DeVoe edited comment on KAFKA-4477 at 12/13/16 5:20 PM: [~junrao] I

Re: [DISCUSS] KIP-83 - Allow multiple SASL PLAIN authenticated Java clients in a single JVM process

Thanks for your review, Ismael. First, I am no longer sure KIP-83 is worth keeping as KIP, I created it just before Rajini's https://cwiki.apache.org/confluence/display/KAFKA/KIP-85%3A+Dynamic+JAAS+configuration+for+Kafka+clients With KIP-85 as presented, my proposal has become a simple JIRA,

[jira] [Updated] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4532: -- Description: When building a topology with tables and StateStores, the StateStores are mapped to the

[jira] [Updated] (KAFKA-4532) StateStores can be connected to the wrong source topic resulting in incorrect metadata returned from IQ

[ https://issues.apache.org/jira/browse/KAFKA-4532?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy updated KAFKA-4532: -- Summary: StateStores can be connected to the wrong source topic resulting in incorrect metadata

Re: [VOTE] KIP-87 - Add Compaction Tombstone Flag

Hi Ismael Did you see our email this morning, what's your thoughts on this approach to instead we simply have a brand new policy? Cheers Mike Sent using OWA for iPhone From: isma...@gmail.com on behalf of Ismael Juma

[jira] [Created] (KAFKA-4533) subscribe() then poll() on new topic is very slow when subscribed to many topics

Sergey Alaev created KAFKA-4533: --- Summary: subscribe() then poll() on new topic is very slow when subscribed to many topics Key: KAFKA-4533 URL: https://issues.apache.org/jira/browse/KAFKA-4533

  1   2   >