[GitHub] kafka pull request #2283: HOTFIX: Convert exception to warning since clearly...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2283 --- 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 enab

[jira] [Updated] (KAFKA-4507) The client should send older versions of requests to the broker if necessary

[ https://issues.apache.org/jira/browse/KAFKA-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4507: - Fix Version/s: 0.10.2.0 > The client should send older versions of requests to the

[jira] [Updated] (KAFKA-4457) Add a command to list the broker version information

[ https://issues.apache.org/jira/browse/KAFKA-4457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4457: - Fix Version/s: 0.10.2.0 > Add a command to list the broker version information > -

[jira] [Updated] (KAFKA-4507) The client should send older versions of requests to the broker if necessary

[ https://issues.apache.org/jira/browse/KAFKA-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4507: - Priority: Blocker (was: Major) > The client should send older versions of request

[jira] [Updated] (KAFKA-4457) Add a command to list the broker version information

[ https://issues.apache.org/jira/browse/KAFKA-4457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4457: - Priority: Blocker (was: Major) > Add a command to list the broker version informa

[jira] [Updated] (KAFKA-4548) Add CompatibilityTest to verify that individual features are supported or not by the broker we're connecting to

[ https://issues.apache.org/jira/browse/KAFKA-4548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4548: - Fix Version/s: 0.10.2.0 > Add CompatibilityTest to verify that individual features

[GitHub] kafka pull request #1957: MINOR: Add Replication Quotas Test Rig

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1957 --- 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 enab

[jira] [Commented] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814359#comment-15814359 ] Umesh Chaudhary commented on KAFKA-4564: Hi [~guozhang], [~ewencp], I am thinking

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

See Changes: [me] TRIVIAL: Fix spelling of log message [me] MINOR: Fix small error in javadoc for persistent Stores -- [...truncated 18065 lines...] org.apache.kafka.streams.KafkaStreamsTest >

[jira] [Comment Edited] (KAFKA-4569) Transient failure in org.apache.kafka.clients.consumer.KafkaConsumerTest.testWakeupWithFetchDataAvailable

[ https://issues.apache.org/jira/browse/KAFKA-4569?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15813892#comment-15813892 ] Umesh Chaudhary edited comment on KAFKA-4569 at 1/10/17 9:18 AM: ---

[jira] [Commented] (KAFKA-4610) getting error:Batch containing 3 record(s) expired due to timeout while requesting metadata from brokers for test2R2P2-1

[ https://issues.apache.org/jira/browse/KAFKA-4610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814494#comment-15814494 ] sandeep kumar singh commented on KAFKA-4610: thanks for reply. yes most of the

[jira] [Commented] (KAFKA-4611) Support custom authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15814508#comment-15814508 ] Edoardo Comar commented on KAFKA-4611: -- Hi, I am not sure what you are asking is not

Re: [VOTE] KIP-105: Addition of Record Level for Sensors

Thanks for the votes, this is now adopted: Binding +1s: Joel, Neha, Sriram, Guozhang, Ismael Non-binding +1: Michael, Matthias, Bill, Damian. Eno > On 9 Jan 2017, at 22:04, Joel Koshy wrote: > > +1 > (although I added a minor comment on the discussion thread) > > On Mon, Jan 9, 2017 at 3:43 A

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

Dongjin, The KIP states: "I compared the compressed size and compression time of 3 1kb-sized messages (3102 bytes in total), with the Draft-implementation of ZStandard Compression Codec and all currently available CompressionCodecs. All elapsed times are the average of 20 trials." But doesn't gi

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

See Changes: [me] HOTFIX: Convert exception introduced in KAFKA-3637 to warning since [me] MINOR: Add Replication Quotas Test Rig -- [...truncated 18072 lines...] org.apache.kafka.streams.Kafk

Re: [DISCUSS] KIP-109: Old Consumer Deprecation

Hi Ewen, I agree that it would be good to clarify what we consider a message format change. The compaction tombstone was a message format change because it would mean that `null` no longer meant delete for compacted topics, so there is a semantics change as well (and the cleaner would have to be

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

Ismael, I see. Then, I will share the benchmark code I used by tomorrow. Thanks for your guidance. Best,Dongjin - Dongjin Lee Software developer in Line+. So interested in massive-scale machine learning. facebook: www.facebook.com/dongjin.lee.kr linkedin: kr.linkedin.com/in/dongjinleekr git

Re: [VOTE] KIP-109: Old Consumer Deprecation

Thanks Vahid. I think there are 2 aspects to this KIP: 1. Deprecating the old consumers 2. When it should be done I think everyone agrees that we should deprecate it, but there is a difference of opinions on the timing. I think it may be best not to rush it, so I'm +1 on this for the release afte

Re: [VOTE] KIP-103: Separation of Internal and External traffic

Thanks to everyone who voted and provided feedback. The vote has passed with 5 binding votes (Sriram, Jun, Neha, Becket, Joel) and 4 non-binding votes (Rajini, Colin, Tom, Roger). I have updated the relevant wiki pages. Ismael On Mon, Jan 9, 2017 at 9:52 PM, Joel Koshy wrote: > +1 > > On Fri,

Re: [VOTE] KIP-102 - Add close with timeout for consumers

Rajini, maybe we can close the vote? Ismael On Fri, Jan 6, 2017 at 7:48 PM, Apurva Mehta wrote: > +1 (non-binding). > > On Fri, Jan 6, 2017 at 9:24 AM, Jason Gustafson > wrote: > > > Thanks for the KIP. +1 > > > > On Fri, Jan 6, 2017 at 2:26 AM, Ismael Juma wrote: > > > > > Thanks for the KIP

[GitHub] kafka pull request #2326: MINOR: Various small scala cleanups

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2326 --- 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 enab

Re: [VOTE] KIP-102 - Add close with timeout for consumers

Yes, Thank you, Ismael. Many thanks to everyone for the feedback and votes. The vote has passed with 5 binding (Neha, Ewen, Sriram, Ismael, Jason) and three non-binding (Edo, Apurva, me) +1s. I will update the KIP pages. Regards, Rajini On Tue, Jan 10, 2017 at 11:33 AM, Ismael Juma wrote: >

[jira] [Updated] (KAFKA-3751) Add support for SASL/SCRAM mechanisms

[ https://issues.apache.org/jira/browse/KAFKA-3751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-3751: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 2086 [https:

[GitHub] kafka pull request #2086: KAFKA-3751: SASL/SCRAM implementation

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2086 --- 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 enab

[jira] [Commented] (KAFKA-3751) Add support for SASL/SCRAM mechanisms

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

[jira] [Commented] (KAFKA-4125) Provide low-level Processor API meta data in DSL layer

[ https://issues.apache.org/jira/browse/KAFKA-4125?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815003#comment-15815003 ] Bill Bejeck commented on KAFKA-4125: [~guozhang] [~mjsax] Thanks for the response. S

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

See Changes: [ismael] MINOR: Remove unnecessary semi-colons -- [...truncated 33841 lines...] org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED org.apache.kafka.streams.KafkaStrea

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

See Changes: [junrao] KAFKA-3751; SASL/SCRAM implementation -- [...truncated 19810 lines...] org.apache.kafka.connect.runtime.WorkerTest > testStopInvalidConnector PASSED org.apache.kafka.conne

[GitHub] kafka pull request #2339: MINOR: rename SessionStore.findSessionsToMerge to ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/2339 MINOR: rename SessionStore.findSessionsToMerge to findSessions Rename `SessionStore.findSessionsToMerge` to `findSessions` You can merge this pull request into a Git repository by running: $ git p

Re: [VOTE] KIP-109: Old Consumer Deprecation

Hi Ismael, Sure, that sounds good to me. Thanks. --Vahid From: Ismael Juma To: dev@kafka.apache.org Date: 01/10/2017 03:26 AM Subject:Re: [VOTE] KIP-109: Old Consumer Deprecation Sent by:isma...@gmail.com Thanks Vahid. I think there are 2 aspects to this KIP: 1.

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

Hi All, We've been putting some thought into the need to buffer fetched data in the consumer in the READ_COMMITTED isolation mode and have a proposal to address the concern. The basic idea is to introduce an index to keep track of the aborted transactions. We use this index to return in each fetch

[jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4609: - Component/s: streams > KTable/KTable join followed by groupBy and aggregate/count can result in >

[GitHub] kafka pull request #2339: MINOR: rename SessionStore.findSessionsToMerge to ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2339 --- 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 enab

[jira] [Updated] (KAFKA-4609) KTable/KTable join followed by groupBy and aggregate/count can result in incorrect results

[ https://issues.apache.org/jira/browse/KAFKA-4609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4609: - Labels: architecture (was: ) > KTable/KTable join followed by groupBy and aggregate/count can res

[jira] [Resolved] (KAFKA-4506) Refactor AbstractRequest to contain version information

[ https://issues.apache.org/jira/browse/KAFKA-4506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4506. -- Resolution: Duplicate Reviewer: Ewen Cheslack-Postava This was absorbed in

[jira] [Commented] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815649#comment-15815649 ] Andrey commented on KAFKA-1251: --- Hi, Does anyone knows why "counter" metrics exposed as "ra

[jira] [Comment Edited] (KAFKA-1251) Add metrics to the producer

[ https://issues.apache.org/jira/browse/KAFKA-1251?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815649#comment-15815649 ] Andrey edited comment on KAFKA-1251 at 1/10/17 5:51 PM: Hi, Does

[GitHub] kafka pull request #2340: MINOR: ConfigDef `parseType` exception message upd...

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/2340 MINOR: ConfigDef `parseType` exception message updated. - When Kafka configurations are provided programmatically, for the below configuration incorrect error message gets printed. * configu

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

See Changes: [wangguoz] MINOR: rename SessionStore.findSessionsToMerge to findSessions -- [...truncated 18210 lines...] org.apache.kafka.streams.processor.internals.StreamsMetadataStateTest > s

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15815872#comment-15815872 ] Guozhang Wang commented on KAFKA-4604: -- Just curious is it only an issue for `ecplise

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

See Changes: [wangguoz] MINOR: rename SessionStore.findSessionsToMerge to findSessions -- [...truncated 5317 lines...] kafka.api.SaslScramSslEndToEndAuthorizationTest > testNoGroupAcl PASSED k

[GitHub] kafka pull request #2305: MINOR: Replacing for with foreach loop in stream t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2305 --- 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 enab

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15816000#comment-15816000 ] Guozhang Wang commented on KAFKA-4604: -- BTW I have just assigned it to you. > Gradle

[jira] [Updated] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4604: - Assignee: Dhwani Katagade > Gradle Eclipse plugin creates projects for non project subfolders > --

[jira] [Updated] (KAFKA-3853) Report offsets for empty groups in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian updated KAFKA-3853: --- Status: Patch Available (was: In Progress) > Report offsets for empty groups in ConsumerGroup

Re: [VOTE] KIP-109: Old Consumer Deprecation

+1 On Mon, Jan 9, 2017 at 8:58 AM, Vahid S Hashemian wrote: > Happy Monday, > > I'd like to thank everyone who participated in the discussion around this > KIP and shared their opinion. > > The only concern that was raised was not having a defined migration plan > yet for existing users of the ol

Re: [DISCUSS] KIP-109: Old Consumer Deprecation

Hi Ismael, What are the expected timelines we are talking about between the major releases? At LI we are expecting to have atleast 1 year between the old consumer deprecation and removal so we have enough time to upgrade all applications. The rollout to new consumer has hit many hurdles so hasn't p

[jira] [Commented] (KAFKA-2963) Replace server internal usage of TopicAndPartition with TopicPartition

[ https://issues.apache.org/jira/browse/KAFKA-2963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15816186#comment-15816186 ] Mickael Maison commented on KAFKA-2963: --- [~sinus] Are you still working on this ? If

[GitHub] kafka pull request #2341: KAFKA-4547: Avoid unnecessary offset commit that c...

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/2341 KAFKA-4547: Avoid unnecessary offset commit that could lead to an invalid offset position if partition is paused You can merge this pull request into a Git repository by running: $ git

[jira] [Commented] (KAFKA-4547) Consumer.position returns incorrect results for Kafka 0.10.1.0 client

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

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

See Changes: [wangguoz] MINOR: Replacing for with foreach loop in stream test classes -- [...truncated 18234 lines...] org.apache.kafka.streams.KafkaStreamsTest > testCleanup STARTED org.apach

Re: [DISCUSS] KIP-109: Old Consumer Deprecation

On Tue, Jan 10, 2017 at 12:53 PM, Renu Tewari wrote: > Hi Ismael, > What are the expected timelines we are talking about between the major > releases? At LI we are expecting to have atleast 1 year between the old > consumer deprecation and removal so we have enough time to upgrade all > applicati

Re: [DISCUSS] KIP-109: Old Consumer Deprecation

Hi Renu, 0.10 was released in May. 2016. 0.11 will be not be before May 2017 (it could be later if the next release turns out to be 0.10.3). So the most recent data indicates a minimum of 1 year between major releases, but no decision has been made on future major release yet. The impact would in

[jira] [Created] (KAFKA-4613) Treat null-key records the same way for joins and aggreations

Matthias J. Sax created KAFKA-4613: -- Summary: Treat null-key records the same way for joins and aggreations Key: KAFKA-4613 URL: https://issues.apache.org/jira/browse/KAFKA-4613 Project: Kafka

Re: [DISCUSS] KIP-107: Add purgeDataBefore() API in AdminClient

Bump up. I am going to initiate the vote If there is no further concern with the KIP. On Fri, Jan 6, 2017 at 11:23 PM, Dong Lin wrote: > Hey Mayuresh, > > Thanks for the comment. If the message's offset is below low_watermark, > then it should have been deleted by log retention policy. Thus it i

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

See Changes: [wangguoz] MINOR: Replacing for with foreach loop in stream test classes -- [...truncated 18215 lines...] org.apache.kafka.streams.processor.internals.RecordCollectorTest > testSpe

[jira] [Resolved] (KAFKA-1027) Add documentation for system tests

[ https://issues.apache.org/jira/browse/KAFKA-1027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-1027. -- Resolution: Won't Fix Assignee: Ewen Cheslack-Postava Fix Version

[jira] [Updated] (KAFKA-3714) Allow users greater access to register custom streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3714: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Allow users great

[jira] [Updated] (KAFKA-3835) Streams is creating two ProducerRecords for each send via RecordCollector

[ https://issues.apache.org/jira/browse/KAFKA-3835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3835: - Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Streams is creati

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4064: - Assignee: Roger Hoover (was: Xavier Léauté) > Add support for infinite endpoints

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4064: - Status: Patch Available (was: Open) > Add support for infinite endpoints for rang

[GitHub] kafka pull request #2342: KAFKA-3452: follow-up -- introduce SesssionWindows

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2342 KAFKA-3452: follow-up -- introduce SesssionWindows - TimeWindows represent half-open time intervals while SessionWindows represent closed time intervals You can merge this pull request into a Git re

[jira] [Commented] (KAFKA-3452) Support session windows

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

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15816852#comment-15816852 ] Dhwani Katagade commented on KAFKA-4604: Hi I have tried it with Eclipse since I

Re: [VOTE] KIP-109: Old Consumer Deprecation

Ismael, Is that regardless of whether it ends up being a major/minor version? i.e. given the way we've phrased (and I think started to follow through on) deprecations, if the next releases were 0.10.3.0 and then 0.11.0.0, the deprecation period would only be one release. That would be a tiny windo

Re: [DISCUSS] KIP-109: Old Consumer Deprecation

It might also be helpful for anyone who has done a bit of thinking around the migration story to dump their thoughts into the JIRA re: the plan. There are also questions I would have around what the exact requirements are. For example, if supporting auto commit is required, things get a lot hairier

[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&focusedCommentId=15817467#comment-15817467 ] Pengwei commented on KAFKA-3042: [~lindong] It seems I still encounter this issue after a

[jira] [Commented] (KAFKA-4610) getting error:Batch containing 3 record(s) expired due to timeout while requesting metadata from brokers for test2R2P2-1

[ https://issues.apache.org/jira/browse/KAFKA-4610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817473#comment-15817473 ] Ewen Cheslack-Postava commented on KAFKA-4610: -- The current timeout for such

[jira] [Reopened] (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:all-tabpanel ] Pengwei reopened KAFKA-3042: > updateIsr should stop after failed several times due to zkVersion issue >

[jira] [Comment Edited] (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&focusedCommentId=15817467#comment-15817467 ] Pengwei edited comment on KAFKA-3042 at 1/11/17 7:27 AM: - [~lindon

[jira] [Commented] (KAFKA-4556) unordered messages when multiple topics are combined in single topic through stream

[ https://issues.apache.org/jira/browse/KAFKA-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15817551#comment-15817551 ] Savdeep Singh commented on KAFKA-4556: -- Can you give a specific example of stream win