[jira] [Resolved] (KAFKA-4188) compilation issues with org.apache.kafka.clients.consumer.internals.Fetcher.java

[ https://issues.apache.org/jira/browse/KAFKA-4188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-4188. -- Resolution: Cannot Reproduce Pl reopen if you think the issue still exists > compilation issues with

[GitHub] kafka pull request #3773: MINOR: Fix unit test failures from last commit, ch...

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

Jenkins build is back to normal : kafka-0.11.0-jdk7 #292

See

Jenkins build is back to normal : kafka-0.10.2-jdk7 #197

See

[GitHub] kafka pull request #3775: KAFKA-5818: KafkaStreams state transitions not cor...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/3775 KAFKA-5818: KafkaStreams state transitions not correct - need to check that state is CRATED at startup - some minor test cleanup You can merge this pull request into a Git repository by running:

[jira] [Created] (KAFKA-5818) Kafka Stream state transitions not correct

Matthias J. Sax created KAFKA-5818: -- Summary: Kafka Stream state transitions not correct Key: KAFKA-5818 URL: https://issues.apache.org/jira/browse/KAFKA-5818 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #3753: Allow timestamp parameter in `ProcessorTopologyTes...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3753 --- 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 #3774: MINOR: Increase timeout of Zookeeper service in sy...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3774 --- 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 #3774: MINOR: Increase timeout of Zookeeper service in sy...

GitHub user rhauch opened a pull request: https://github.com/apache/kafka/pull/3774 MINOR: Increase timeout of Zookeeper service in system tests The previous timeout was 10 seconds, but system test failures have occurred when Zookeeper has started after about 11 seconds. Increasing

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

See

Build failed in Jenkins: kafka-0.10.2-jdk7 #196

See Changes: [rajinisivaram] MINOR: Fix unit test failures from last commit, cherry-pick fix for SASL -- [...truncated 159.37 KB...] kafka.server.KafkaConfigTest >

Re: [DISCUSS] KIP-188 - Add new metrics to support health checks

Hi Jun, Thank you, that makes sense. Updated the KIP. Regards, Rajini On Thu, Aug 31, 2017 at 12:35 PM, Jun Rao wrote: > Hi, Rajini, > > Thanks for the updated KIP. Should be also track the conversion time for > the producer? If so, the name can just be

[GitHub] kafka pull request #3755: KAFKA-5806. Fix transient unit test failure in tro...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3755 --- 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-5806) Fix transient unit test failure in trogdor coordinator shutdown

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

[jira] [Resolved] (KAFKA-3647) Unable to set a ssl provider

[ https://issues.apache.org/jira/browse/KAFKA-3647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3647. -- Resolution: Fixed Closing as per above comments. > Unable to set a ssl provider >

Re: [DISCUSS] KIP-185: Make exactly once in order delivery per partition the default producer setting

Makes sense in terms of priorities. Thanks, Apurva. On Thu, Aug 31, 2017 at 11:15 AM, Apurva Mehta wrote: > Thanks for the message, Roger. > > I think having 'acks=all' imply 'acks=minIsr' will probably result in some > improvement in the latency. However, I would note two

[jira] [Resolved] (KAFKA-3079) org.apache.kafka.common.KafkaException: java.lang.SecurityException: Configuration Error:

[ https://issues.apache.org/jira/browse/KAFKA-3079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-3079. -- Resolution: Cannot Reproduce Mostly related to config error. Pl reopen if you think the issue still

[jira] [Resolved] (KAFKA-2986) Consumer group doesn't lend itself well for slow consumers with varying message size

[ https://issues.apache.org/jira/browse/KAFKA-2986?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2986. -- Resolution: Fixed Fixed in newer versions. Pl reopen if you think the issue still exists > Consumer

Re: [VOTE] KIP-189 - Improve principal builder interface and add support for SASL

+1 (non binding) Thanks for the KIP On Thu, Aug 31, 2017 at 10:10 AM, Jun Rao wrote: > That's also fine as long as it's documented in the interface somehow. The > only thing with java Closeable is that it throws IOException. In most of > our usage, we use close() with no

[jira] [Resolved] (KAFKA-2897) Class NIOServerCnxn$Factory not found due to mismatch in dependencies

[ https://issues.apache.org/jira/browse/KAFKA-2897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2897. -- Resolution: Won't Fix Closing inactive issue. Pl reopen if you think the issue still exists > Class

[jira] [Resolved] (KAFKA-2842) BrokerEndPoint regex does't support hostname with _

[ https://issues.apache.org/jira/browse/KAFKA-2842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2842. -- Resolution: Fixed This was fixed in KAFKA-3719 > BrokerEndPoint regex does't support hostname with _ >

[jira] [Resolved] (KAFKA-2750) Sender.java: handleProduceResponse does not check protocol version

[ https://issues.apache.org/jira/browse/KAFKA-2750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2750. -- Resolution: Fixed This was fixed in KAFKA-4462 /KIP-97 for newer clients > Sender.java:

[GitHub] kafka pull request #3773: MINOR: Fix unit test failures from last commit, ch...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/3773 MINOR: Fix unit test failures from last commit, cherry-pick fix for SASL principal You can merge this pull request into a Git repository by running: $ git pull

Re: [DISCUSS] KIP-190: Handle client-ids consistently between clients and brokers

Even though it's pretty non controversial, I was expecting a few comments. I'll wait until next week for comments then I'll start the vote. Thanks On Mon, Aug 21, 2017 at 6:51 AM, Mickael Maison wrote: > Hi all, > > I have created a KIP to cleanup the way client-ids

[jira] [Resolved] (KAFKA-2343) Clarify KafkaConsumer.poll rebalance behavior

[ https://issues.apache.org/jira/browse/KAFKA-2343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2343. -- Resolution: Fixed Javadocs updated in newer versions. > Clarify KafkaConsumer.poll rebalance behavior

Build failed in Jenkins: kafka-0.11.0-jdk7 #291

See Changes: [ismael] KAFKA-2105; Check for null in KafkaProducer.partitionsFor -- [...truncated 2.44 MB...]

[jira] [Resolved] (KAFKA-2028) Unable to start the ZK instance after myid file was missing and had to recreate it.

[ https://issues.apache.org/jira/browse/KAFKA-2028?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-2028. -- Resolution: Fixed related to config issue. Pl reopen if you think the issue still exists > Unable to

[jira] [Resolved] (KAFKA-908) Write duplicate messages during broker failure

[ https://issues.apache.org/jira/browse/KAFKA-908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-908. - Resolution: Fixed Closing inactive issue. Pl reopen if you think the issue still exists > Write duplicate

[jira] [Resolved] (KAFKA-1138) Remote producer uses the hostname defined in broker

[ https://issues.apache.org/jira/browse/KAFKA-1138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1138. -- Resolution: Fixed > Remote producer uses the hostname defined in broker >

[GitHub] kafka pull request #3772: KAFKA-5817: Add Serialized class and overloads to ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3772 KAFKA-5817: Add Serialized class and overloads to KStream#groupBy and KStream#groupByKey Part of KIP-182 - Add the `Serialized` class - implement overloads of `KStream#groupByKey` and

Re: [DISCUSS] KIP-185: Make exactly once in order delivery per partition the default producer setting

Thanks for the message, Roger. I think having 'acks=all' imply 'acks=minIsr' will probably result in some improvement in the latency. However, I would note two things: 1. The numbers on the wiki are latency at max throughput, which should not be representative of actual latency degradation. We

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

See Changes: [rajinisivaram] MINOR: Test SASL authorization id -- [...truncated 914.44 KB...] kafka.server.epoch.LeaderEpochFileCacheTest >

[GitHub] kafka pull request #3771: MINOR: logging improvements

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3771 MINOR: logging improvements This is a manual cherry-pick of https://github.com/apache/kafka/pull/3769 for 0.11.0 You can merge this pull request into a Git repository by running: $ git

[jira] [Resolved] (KAFKA-1920) Add a metric to count client side errors in BrokerTopicMetrics

[ https://issues.apache.org/jira/browse/KAFKA-1920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1920. -- Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Add a metric to count client side

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

See

[jira] [Resolved] (KAFKA-1402) Create unit test helper that stops and starts a cluster

[ https://issues.apache.org/jira/browse/KAFKA-1402?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1402. -- Resolution: Fixed We have KafkaServerTestHarness, EmbeddedKafkaCluster, EmbeddedZookeeper helper

[jira] [Created] (KAFKA-5817) Add Serialized class and KStream groupBy and groupByKey overloads

Damian Guy created KAFKA-5817: - Summary: Add Serialized class and KStream groupBy and groupByKey overloads Key: KAFKA-5817 URL: https://issues.apache.org/jira/browse/KAFKA-5817 Project: Kafka

[GitHub] kafka pull request #3770: KAFKA-5816: add Produced class, KStream#to(topic, ...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3770 KAFKA-5816: add Produced class, KStream#to(topic, Produced), and KStream#through(topic, Produced) Add the `Produced` class and `KStream` overloads that use it: `KStream#to(String, Produced)`

[jira] [Created] (KAFKA-5816) Add Produced class and new to and through overloads to KStream

Damian Guy created KAFKA-5816: - Summary: Add Produced class and new to and through overloads to KStream Key: KAFKA-5816 URL: https://issues.apache.org/jira/browse/KAFKA-5816 Project: Kafka

[jira] [Created] (KAFKA-5815) Add Printed class and KStream#print(Printed)

Damian Guy created KAFKA-5815: - Summary: Add Printed class and KStream#print(Printed) Key: KAFKA-5815 URL: https://issues.apache.org/jira/browse/KAFKA-5815 Project: Kafka Issue Type: Sub-task

Re: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 On 8/31/17 8:49 AM, Jason Gustafson wrote: > +1 > > On Thu, Aug 31, 2017 at 8:36 AM, Mickael Maison > wrote: > >> +1 non binding >> Thanks >> >> On Thu, Aug 31, 2017 at 8:35 AM, Guozhang Wang wrote: >>> ＋1 >>> >>> On Thu, Aug 31, 2017 at 7:57

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

See

Re: [VOTE] KIP-189 - Improve principal builder interface and add support for SASL

That's also fine as long as it's documented in the interface somehow. The only thing with java Closeable is that it throws IOException. In most of our usage, we use close() with no exception since it's not clear what you will do when an exception is thrown in close(). Thanks, Jun On Thu, Aug

[GitHub] kafka pull request #3769: MINOR: Log encountered exception during rebalance

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/3769 MINOR: Log encountered exception during rebalance Some other minor changes: 1. Do not throw the exception form callback as it would only be swallowed by consumer coordinator;

Re: [VOTE] KIP-189 - Improve principal builder interface and add support for SASL

Hey Jun, I will add a note to the KIP, but my plan was to dynamically check whether the KafkaPrincipalBuilder implemented Configurable or Closeable. That makes implementing close() and configure() optional. Does that seem reasonable? -Jason On Thu, Aug 31, 2017 at 9:53 AM, Jun Rao

[jira] [Resolved] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1447. -- Resolution: Fixed Pl reopen if you think the issue still exists > Controlled shutdown deadlock when

Re: [VOTE] KIP-189 - Improve principal builder interface and add support for SASL

Hi, Jason, Thanks for the KIP. +1. Just one minor comment. It seems that the new KafkaPrincipalBuilder interface should support Configurable and close() as the existing PrincipalBuilder? Jun On Wed, Aug 30, 2017 at 8:51 AM, Jason Gustafson wrote: > I'd like to open the

Re: [VOTE] KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient

Hi, Tom, Thanks for the KIP. +1. Just one more minor comment. It seems that the ElectPreferredLeadersResponse should expect at least 3 other types of errors : (1) request timeout exception, (2) leader rebalance in-progress exception, (3) can't move to the preferred replica exception (i.e.,

Build failed in Jenkins: kafka-0.10.2-jdk7 #195

See Changes: [rajinisivaram] MINOR: Test SASL authorization id -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on H26

[GitHub] kafka pull request #3766: MINOR: Test SASL authorization id

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3766 --- 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-4905) StreamPartitionAssignor doesn't respect subscriptions to assign partitions.

[ https://issues.apache.org/jira/browse/KAFKA-4905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4905. -- Resolution: Not A Problem > StreamPartitionAssignor doesn't respect subscriptions to assign

Re: [DISCUSS] KIP-185: Make exactly once in order delivery per partition the default producer setting

Sorry, my math was sloppy. It's not twice as many requests taking longer. If the probability of replication latency longer than X is Px for both replicas then, acks=all will have probability of Px(2-Px) of replication lag longer than X while acks=minIsr will be Px On Wed, Aug 30, 2017 at 5:18

Re: CredentialCache might leak through Log

Hi Rodrigo, What attacks are possible if this info is exposed? I think printing the first one on debug is ok since that mode shouldn't be enabled in production, while it might be very useful while debugging. For the second one I could agree that we should print a sanitized warn depending on the

[jira] [Resolved] (KAFKA-818) Request failure metrics on the Kafka brokers is not instrumented for all requests

[ https://issues.apache.org/jira/browse/KAFKA-818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-818. - Resolution: Duplicate Similar metrics are proposed in KAFKA-5746. > Request failure metrics on the Kafka

[GitHub] kafka pull request #3768: KAFKA:5652 add Printed class and KStream#print(pri...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3768 KAFKA:5652 add Printed class and KStream#print(printed) Part of KIP-182 - Add `Printed` class and `KStream#print(Printed)` - deprecate all other `print` and `writeAsText` methods You can merge

Re: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 On Thu, Aug 31, 2017 at 8:36 AM, Mickael Maison wrote: > +1 non binding > Thanks > > On Thu, Aug 31, 2017 at 8:35 AM, Guozhang Wang wrote: > > ＋1 > > > > On Thu, Aug 31, 2017 at 7:57 AM, Bill Bejeck wrote: > > > >> +1 > >> >

[GitHub] kafka pull request #3757: KAFKA-5379 follow up: reduce redundant mock proces...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3757 --- 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: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 non binding Thanks On Thu, Aug 31, 2017 at 8:35 AM, Guozhang Wang wrote: > ＋1 > > On Thu, Aug 31, 2017 at 7:57 AM, Bill Bejeck wrote: > >> +1 >> >> Thanks, >> Bill >> >> On Thu, Aug 31, 2017 at 10:31 AM, Vahid S Hashemian < >> vahidhashem...@us.ibm.com>

Re: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

＋1 On Thu, Aug 31, 2017 at 7:57 AM, Bill Bejeck wrote: > +1 > > Thanks, > Bill > > On Thu, Aug 31, 2017 at 10:31 AM, Vahid S Hashemian < > vahidhashem...@us.ibm.com> wrote: > > > +1 (non-binding) > > > > Thanks. > > --Vahid > > > > > > > > > > From: Molnár Bálint

[GitHub] kafka pull request #3697: KAFKA-2105: add topic null check to KafkaProducer....

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3697 --- 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: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 Thanks, Bill On Thu, Aug 31, 2017 at 10:31 AM, Vahid S Hashemian < vahidhashem...@us.ibm.com> wrote: > +1 (non-binding) > > Thanks. > --Vahid > > > > > From: Molnár Bálint > To: dev@kafka.apache.org > Date: 08/31/2017 02:13 AM > Subject:Re: [VOTE]

Re: [VOTE] KIP-182 - Reduce Streams DSL overloads and allow easier use of custom storage engines

Thanks everyone for voting! Unfortunately i've had to make a bit of an update based on some issues found during implementation. The main changes are: BytesStoreSupplier -> StoreSupplier Addition of: WindowBytesStoreSupplier, KeyValueBytesStoreSupplier, SessionBytesStoreSupplier that will restrict

[GitHub] kafka pull request #3767: KAFKA-5650: add StateStoreBuilder interface and im...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/3767 KAFKA-5650: add StateStoreBuilder interface and implementations Part of KIP-182 - Add `StateStoreBuilder` interface and `WindowStateStoreBuilder`, `KeyValueStateStoreBuilder`, and

Re: [DISCUSS] KIP-188 - Add new metrics to support health checks

Hi Rajini, Yes, It provides the failure rate for all errors. I got confused with old metric names. Thank you for the clarification. Thanks On Thu, Aug 31, 2017 at 6:34 PM, Rajini Sivaram wrote: > Hi Manikumar, > > We currently have topic-level metrics for

Re: [VOTE] KIP-152 - Improve diagnostics for SASL authentication failures

This vote has passed with 5 binding (Jun, Ismael, Jason, Gwen, me) and 5 non-binding (Edo, Vahid, Manikumar, Mickael and Roger) votes. Many thanks to every one for the feedback and votes. I will update the KIP page. Regards, Rajini On Wed, Aug 30, 2017 at 1:22 PM, Gwen Shapira

Re: [DISCUSS] KIP-188 - Add new metrics to support health checks

Hi Roger, Yes, the rate metrics `successful-authentication-rate` and ` failed-authentication-rate` will also have corresponding failed-authentication-count and successful-authentication-count to match KIP 187. Thank you, Rajini On Tue, Aug 29, 2017 at 1:07 PM, Roger Hoover

Re: [DISCUSS] KIP-188 - Add new metrics to support health checks

Hi Manikumar, We currently have topic-level metrics for FailedProduceRequestsPerSec, FailedFetchRequestsPerSec. For all requests including produce/fetch, this KIP adds a new error rate metric: MBean: kafka.network:type=RequestMetrics,name=ErrorsPerSec,request=api_key_name,error=error_code_name

Re: [VOTE] KIP-183 - Change PreferredReplicaLeaderElectionCommand to use AdminClient

Thanks for the KIP, +1 (binding) from me. Ismael On Tue, Aug 29, 2017 at 4:56 PM, Tom Bentley wrote: > Hi all, > > I would like to start the vote on KIP-183 which will provide an AdminClient > interface for electing the preferred replica, and refactor the >

Re: [DISCUSS] KIP-188 - Add new metrics to support health checks

Hi, Currently, we have FailedProduceRequestsPerSec, FailedFetchRequestsPerSec metrics to indicate un-expected failures on a broker while handling producer/fetch requests. Will it be useful to add these metrics for other requests also? I don't want to include these metrics to this KIP. Just want

[GitHub] kafka pull request #3759: [WIP]: extract and make public KeySchema & HasNext...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/3759 --- 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: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 (non-binding) 2017-08-31 10:33 GMT+02:00 Manikumar : > +1 (non-binding) > > On Thu, Aug 31, 2017 at 1:53 PM, Ismael Juma wrote: > > > Thanks for the KIP, +1 (binding). > > > > Ismael > > > > On 31 Aug 2017 8:38 am, "Attila Kreiner"

Re: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

+1 (non-binding) On Thu, Aug 31, 2017 at 1:53 PM, Ismael Juma wrote: > Thanks for the KIP, +1 (binding). > > Ismael > > On 31 Aug 2017 8:38 am, "Attila Kreiner" wrote: > > Hi All, > > Thx for the comments, I pretty much see a consensus here. So I'd like to

Re: [VOTE] KIP-138: Change punctuate semantics

+0 ambivalent about the naming but do agree that should be kept consistent On 31/08/17 00:43, Matthias J. Sax wrote: +1 On 8/30/17 12:00 PM, Bill Bejeck wrote: +1 On Wed, Aug 30, 2017 at 1:06 PM, Damian Guy wrote: +1 On Wed, 30 Aug 2017 at 17:49 Guozhang Wang

Re: [VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

Thanks for the KIP, +1 (binding). Ismael On 31 Aug 2017 8:38 am, "Attila Kreiner" wrote: Hi All, Thx for the comments, I pretty much see a consensus here. So I'd like to start the vote for: https://cwiki.apache.org/confluence/display/KAFKA/KIP-191%3A+KafkaConsumer.

[jira] [Created] (KAFKA-5814) java.lang.OutOfMemoryError: Direct buffer memory

Alexander Petrovsky created KAFKA-5814: -- Summary: java.lang.OutOfMemoryError: Direct buffer memory Key: KAFKA-5814 URL: https://issues.apache.org/jira/browse/KAFKA-5814 Project: Kafka

[VOTE] KIP-191: KafkaConsumer.subscribe() overload that takes just Pattern

Hi All, Thx for the comments, I pretty much see a consensus here. So I'd like to start the vote for: https://cwiki.apache.org/confluence/display/KAFKA/KIP-191%3A+KafkaConsumer.subscribe%28%29+overload+that+takes+just+Pattern Cheers, Attila

[GitHub] kafka pull request #3765: KAFKA-5642 [WIP]: Use async ZookeeperClient in Con...

GitHub user onurkaraman opened a pull request: https://github.com/apache/kafka/pull/3765 KAFKA-5642 [WIP]: Use async ZookeeperClient in Controller Synchronous zookeeper writes means that we wait an entire round trip before doing the next write. These synchronous writes are

[GitHub] kafka pull request #3764: view diff

GitHub user liwuchuai opened a pull request: https://github.com/apache/kafka/pull/3764 view diff view diff You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/kafka 0.8.1 Alternatively you can review and apply these changes

[jira] [Resolved] (KAFKA-1347) Create a system test for network partitions

[ https://issues.apache.org/jira/browse/KAFKA-1347?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-1347. -- Resolution: Duplicate This is being fixed in KAFKA-5476. > Create a system test for network partitions