Re: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

Hi Matthew, If you're sharing a ZK ensemble and you have a specific path for the Kafka znodes, then you need to use a chroot for this. Just pass it along with the connect string: http://zookeeper.apache.org/doc/r3.4.6/zookeeperProgrammers.html#ch_zkSessions

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085300#comment-15085300 ] Flavio Junqueira commented on KAFKA-3038: - You don't really need to batch with mul

[GitHub] kafka pull request: Grammar on README.md

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

[jira] [Commented] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085389#comment-15085389 ] vijay bhaskar commented on KAFKA-664: - I am seeing similar errors on Kafka which is run

[jira] [Commented] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085427#comment-15085427 ] Ismael Juma commented on KAFKA-664: --- Vijay, you should probably file a new issue and incl

RE: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

Hi Flavio, We're not using a chroot for Kafka itself as the ensemble is (mostly) not shared. We do have 1 or two extra branches that are used for some custom programs that use our Kafka infrastructure (each of these branches are used as a chroot). In hindsight using a separate chroot for Kafk

Re: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

You're right, we should set the root ACL separately instead of starting the recursion on the root. One other reason for doing this is that there is at least one persistent branch we don't want to secure (ConsumersPath). I'll create a jira for this and fix it. -Flavio > On 06 Jan 2016, at 14:09

Re: KIP-41: KafkaConsumer Max Records

Thanks Jason. I read the KIP and it makes sense to me. A minor suggestion: in the "Ensuring Fair Consumption" section, there are 3 paragraphs with 2 examples (2 partitions with 100 max.poll.records and 3 partitions with 30 max.poll.records). I think you could simplify this by using one of the examp

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085618#comment-15085618 ] Eno Thereska commented on KAFKA-3068: - [~ijuma], [~hachikuji]: I think a proper soluti

[jira] [Created] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

Flavio Junqueira created KAFKA-3069: --- Summary: Fix recursion in ZkSecurityMigrator Key: KAFKA-3069 URL: https://issues.apache.org/jira/browse/KAFKA-3069 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

[ https://issues.apache.org/jira/browse/KAFKA-3069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-3069: --- Assignee: Flavio Junqueira > Fix recursion in ZkSecurityMigrator > --

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085628#comment-15085628 ] Eno Thereska commented on KAFKA-3038: - [~fpj]: makes sense, thanks > Speeding up part

[jira] [Updated] (KAFKA-2757) Consolidate BrokerEndPoint and EndPoint

[ https://issues.apache.org/jira/browse/KAFKA-2757?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeff Holoman updated KAFKA-2757: Assignee: (was: Jeff Holoman) > Consolidate BrokerEndPoint and EndPoint > --

[jira] [Comment Edited] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085618#comment-15085618 ] Eno Thereska edited comment on KAFKA-3068 at 1/6/16 3:15 PM: -

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085663#comment-15085663 ] Ismael Juma commented on KAFKA-3068: [~enothereska], I agree that a better solution wo

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085682#comment-15085682 ] Eno Thereska commented on KAFKA-3068: - [~ijuma]: a slightly different solution would b

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085688#comment-15085688 ] Ismael Juma commented on KAFKA-3068: Yeah. Or expire brokers based on time. Let's see

[GitHub] kafka pull request: KAFKA-3065: Remove unused topic partitions fro...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/735 KAFKA-3065: Remove unused topic partitions from RecordAccumulator Removes unused topic partitions from RecordAccumulator#batches to prevent the map growing indefinitely. Replaces CopyOnWriteMap

[jira] [Commented] (KAFKA-3065) Prevent unbounded growth of RecordAccumulator#batches in Kafka producer

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

Re: [VOTE] KIP-32 Add CreateTime and LogAppendTime to Kafka message.

Thanks a lot for the careful reading, Jun. Please see inline replies. > On Jan 6, 2016, at 3:24 AM, Jun Rao wrote: > > Jiangjie, > > Thanks for the updated KIP. Overall, a +1 on the proposal. A few minor > comments on the KIP. > > KIP-32: > 50. 6.c says "The log rolling has to depend on the e

[jira] [Created] (KAFKA-3070) SASL unit tests dont work with IBM JDK

Rajini Sivaram created KAFKA-3070: - Summary: SASL unit tests dont work with IBM JDK Key: KAFKA-3070 URL: https://issues.apache.org/jira/browse/KAFKA-3070 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3065) Prevent unbounded growth of RecordAccumulator#batches in Kafka producer

[ https://issues.apache.org/jira/browse/KAFKA-3065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3065: -- Status: Patch Available (was: Open) PR deletes unused entries from RecordAccumulator#batches. T

[jira] [Updated] (KAFKA-2948) Kafka producer does not cope well with topic deletions

[ https://issues.apache.org/jira/browse/KAFKA-2948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-2948: -- Status: Patch Available (was: Open) > Kafka producer does not cope well with topic deletions >

Re: [VOTE] KIP-32 Add CreateTime and LogAppendTime to Kafka message.

Hey Jay, I agree with your comments on the KIP page. As you said it is important to document what are the changes and why we made those decisions. I have added summaries to the page to help readers understand the decision we made more easily and also try to avoid being too verbose. I also clari

[GitHub] kafka pull request: KAFKA-3069: Fix recursion in ZkSecurityMigrato...

GitHub user fpj opened a pull request: https://github.com/apache/kafka/pull/736 KAFKA-3069: Fix recursion in ZkSecurityMigrator I'm also fixing a bug in the testChroot test case. You can merge this pull request into a Git repository by running: $ git pull https://github.com/fpj

[jira] [Commented] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

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

Re: [VOTE] KIP-32 Add CreateTime and LogAppendTime to Kafka message.

Hi, Jiangjie, 52. Replacing MessageSet with o.a.k.common.record will be ideal. Unfortunately, we use MessageSet in SimpleConsumer, which is part of the public api. Replacing MessageSet with o.a.k.common.record will be an incompatible api change. So, we probably should do this after we deprecate Si

[jira] [Commented] (KAFKA-3016) Add KStream-KStream window joins

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

[GitHub] kafka pull request: KAFKA-3016: phase-2. stream join implementatio...

GitHub user ymatsuda opened a pull request: https://github.com/apache/kafka/pull/737 KAFKA-3016: phase-2. stream join implementations @guozhangwang You can merge this pull request into a Git repository by running: $ git pull https://github.com/ymatsuda/kafka windowed_join2 A

[GitHub] kafka pull request: KAFKA-2975

Github user MayureshGharat closed the pull request at: https://github.com/apache/kafka/pull/658 --- 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] [Commented] (KAFKA-2975) The newtorkClient should request a metadata update after it gets an error in the handleResponse()

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

[jira] [Created] (KAFKA-3071) Kafka Server 0.8.2 ERROR OOME with siz

vijay bhaskar created KAFKA-3071: Summary: Kafka Server 0.8.2 ERROR OOME with siz Key: KAFKA-3071 URL: https://issues.apache.org/jira/browse/KAFKA-3071 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-664) Kafka server threads die due to OOME during long running test

[ https://issues.apache.org/jira/browse/KAFKA-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086165#comment-15086165 ] vijay bhaskar commented on KAFKA-664: - Thanks for the suggestion, Ismael. I have create

[jira] [Resolved] (KAFKA-1059) Improve the patch review tool to use OAuth for JIRA access

[ https://issues.apache.org/jira/browse/KAFKA-1059?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-1059. Resolution: Won't Fix Assignee: Grant Henke (was: Neha Narkhede) Closing because the patch re

[GitHub] kafka pull request: KAFKA-3070: Use IBM Kerberos module for SASL t...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/738 KAFKA-3070: Use IBM Kerberos module for SASL tests if running on IBM JDK Use IBM Kerberos module and properties for SASL tests if using IBM JRE You can merge this pull request into a Git reposi

[GitHub] kafka pull request: KAFKA-1901: follow-up on KAFKA-1901; Added err...

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

[jira] [Updated] (KAFKA-3070) SASL unit tests dont work with IBM JDK

[ https://issues.apache.org/jira/browse/KAFKA-3070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-3070: -- Status: Patch Available (was: Open) > SASL unit tests dont work with IBM JDK >

[jira] [Commented] (KAFKA-1901) Move Kafka version to be generated in code by build (instead of in manifest)

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

[jira] [Commented] (KAFKA-3070) SASL unit tests dont work with IBM JDK

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

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086375#comment-15086375 ] Jun Rao commented on KAFKA-2937: The situation that [~mgharat] described can indeed happen

[jira] [Updated] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

[ https://issues.apache.org/jira/browse/KAFKA-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2937: --- Resolution: Fixed Fix Version/s: 0.9.0.1 Status: Resolved (was: Patch Available) Issue reso

[GitHub] kafka pull request: KAFKA-2937 : Disable the leaderIsr check if th...

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

[jira] [Commented] (KAFKA-2937) Topics marked for delete in Zookeeper may become undeletable

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

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

See Changes: [wangguoz] KAFKA-1901; Added error handling when no file exists in .git/refs/heads. -- [...truncated 6951 lines...] org.apache.kafka.connect.storage.KafkaConfigStorageTest > testRes

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

See Changes: [wangguoz] KAFKA-1901; Added error handling when no file exists in .git/refs/heads. -- [...truncated 1782 lines...] kafka.admin.AddPartitionsTest > testTopicDoesNotExist PASSED ka

[GitHub] kafka pull request: KAFKA-3016: phase-2. stream join implementatio...

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

[jira] [Resolved] (KAFKA-3016) Add KStream-KStream window joins

[ https://issues.apache.org/jira/browse/KAFKA-3016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3016. -- Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 737 [https://gith

[jira] [Commented] (KAFKA-3016) Add KStream-KStream window joins

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

[jira] [Resolved] (KAFKA-2850) SslTransportLayerTest.testInvalidEndpointIdentification fails consistently

[ https://issues.apache.org/jira/browse/KAFKA-2850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2850. Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 546 [https://github.com/apach

[GitHub] kafka pull request: KAFKA-2850: Fix SSL invalid endpoint validatio...

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

[jira] [Commented] (KAFKA-2850) SslTransportLayerTest.testInvalidEndpointIdentification fails consistently

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

[jira] [Commented] (KAFKA-2887) TopicMetadataRequest creates topic if it does not exist

[ https://issues.apache.org/jira/browse/KAFKA-2887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086470#comment-15086470 ] Mayuresh Gharat commented on KAFKA-2887: [~hachikuji] just wanted to know if we ha

[GitHub] kafka pull request: KAFKA-2874: shutdown ZK process reliably

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

[jira] [Resolved] (KAFKA-2874) zookeeper-server-stop.sh may fail to shutdown ZK and/or may stop unrelated processes

[ https://issues.apache.org/jira/browse/KAFKA-2874?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-2874. Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 573 [https://github.com/apach

[jira] [Commented] (KAFKA-2874) zookeeper-server-stop.sh may fail to shutdown ZK and/or may stop unrelated processes

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

[jira] [Created] (KAFKA-3072) Client should only allow commits for assigned partitions

Jason Gustafson created KAFKA-3072: -- Summary: Client should only allow commits for assigned partitions Key: KAFKA-3072 URL: https://issues.apache.org/jira/browse/KAFKA-3072 Project: Kafka Is

[jira] [Updated] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

[ https://issues.apache.org/jira/browse/KAFKA-2072?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2072: --- Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was: Patch Available) Issue reso

[GitHub] kafka pull request: KAFKA-2072: Replace StopReplica Request/Respon...

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

[jira] [Commented] (KAFKA-2072) Add StopReplica request/response to o.a.k.common.requests and replace the usage in core module

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

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

See

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086554#comment-15086554 ] Jason Gustafson commented on KAFKA-3068: [~ijuma],[~enothereska] Introducing a not

[jira] [Commented] (KAFKA-3022) Deduplicate common project configurations

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

[GitHub] kafka pull request: KAFKA-3022: Deduplicate common project configu...

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

[jira] [Updated] (KAFKA-3022) Deduplicate common project configurations

[ https://issues.apache.org/jira/browse/KAFKA-3022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3022: - Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved

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

See Changes: [junrao] KAFKA-2937; Disable the leaderIsr check if the topic is to be deleted. [wangguoz] KAFKA-3016: phase-2. stream join implementations [junrao] KAFKA-2850; Fix SSL invalid endpoint validation test --

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

See Changes: [junrao] KAFKA-2874; shutdown ZK process reliably [junrao] KAFKA-2072; Replace StopReplica Request/Response with their [me] KAFKA-3022: Deduplicate common project configurations --

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086580#comment-15086580 ] Ismael Juma commented on KAFKA-3068: It does to me. > NetworkClient may connect to a

[jira] [Created] (KAFKA-3073) KafkaConnect should support regular expression for topics

Gwen Shapira created KAFKA-3073: --- Summary: KafkaConnect should support regular expression for topics Key: KAFKA-3073 URL: https://issues.apache.org/jira/browse/KAFKA-3073 Project: Kafka Issue T

[jira] [Created] (KAFKA-3074) Regex sink connector support

Ewen Cheslack-Postava created KAFKA-3074: Summary: Regex sink connector support Key: KAFKA-3074 URL: https://issues.apache.org/jira/browse/KAFKA-3074 Project: Kafka Issue Type: Bug

[jira] [Resolved] (KAFKA-3074) Regex sink connector support

[ https://issues.apache.org/jira/browse/KAFKA-3074?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3074. - Resolution: Duplicate > Regex sink connector support > > >

Re: KIP-41: KafkaConsumer Max Records

Thanks for the suggestion, Ismael. I updated the KIP. -Jason On Wed, Jan 6, 2016 at 6:57 AM, Ismael Juma wrote: > Thanks Jason. I read the KIP and it makes sense to me. A minor suggestion: > in the "Ensuring Fair Consumption" section, there are 3 paragraphs with 2 > examples (2 partitions with

Re: KIP-41: KafkaConsumer Max Records

I like the fair-consumption approach you chose - "pull as many records as possible from each partition in a similar round-robin fashion", it is very intuitive and close enough to fair. Overall, I'm +1 on the KIP. But you'll need a formal vote :) On Wed, Jan 6, 2016 at 6:05 PM, Jason Gustafson wr

Re: [DISCUSS] KIP-36 - Rack aware replica assignment

Updated KIP according to Jun's comment and included changes to TMR. On Tue, Jan 5, 2016 at 5:59 PM, Jun Rao wrote: > Hi, Allen, > > A couple of minor comments on the KIP. > > 1. The version of the broker JSON string says 2. It should be 3. > > 2. The new version of UpdateMetadataRequest should b

[jira] [Commented] (KAFKA-3068) NetworkClient may connect to a different Kafka cluster than originally configured

[ https://issues.apache.org/jira/browse/KAFKA-3068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086717#comment-15086717 ] Jun Rao commented on KAFKA-3068: There are 2 possible ways of configuring bootstrap server

[jira] [Created] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

Pengwei created KAFKA-3075: -- Summary: java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets Key: KAFKA-3075 URL: https://issues.apache.org/jira/browse/KA

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-3075: --- Description: When using java api's commit offset : public void commitOffsets(Map offsetsToCommit, boolean r

[jira] [Updated] (KAFKA-3075) java.util.HashMap cannot be cast to scala.collection.immutable.Map When using ZookeeperConsumerConnector.commitOffsets

[ https://issues.apache.org/jira/browse/KAFKA-3075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pengwei updated KAFKA-3075: --- Description: When using java api's commit offset : public void commitOffsets(Map offsetsToCommit, boolean r

[jira] [Updated] (KAFKA-2929) Migrate server side error mapping functionality

[ https://issues.apache.org/jira/browse/KAFKA-2929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2929: - Resolution: Fixed Fix Version/s: 0.9.1.0 Status: Resolved (was:

[GitHub] kafka pull request: KAFKA-2929: Migrate duplicate error mapping fu...

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

[jira] [Commented] (KAFKA-2929) Migrate server side error mapping functionality

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

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

See Changes: [me] KAFKA-2929: Migrate duplicate error mapping functionality -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu3 (Ubuntu ubun

[jira] [Commented] (KAFKA-2426) A Kafka node tries to connect to itself through its advertised hostname

[ https://issues.apache.org/jira/browse/KAFKA-2426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15086853#comment-15086853 ] Mikaël Cluseau commented on KAFKA-2426: --- Hi Matt, yes, the only way to make it work