Re: custom offsets in ProduceRequest

Hi! > On 30 Dec 2016, at 09:52, radai wrote: > > or even better - if topic creation is done dynamically by the replicator, > setting the initial offsets for partitions could be made part of topic > creation ? even less API changes this way > > On Thu, Dec 29, 2016 at 10:49 PM, radai wrote: >

[jira] [Created] (KAFKA-4576) Log segments close to max size break on fetch

Ivan Babrou created KAFKA-4576: -- Summary: Log segments close to max size break on fetch Key: KAFKA-4576 URL: https://issues.apache.org/jira/browse/KAFKA-4576 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-4572) Kafka connect for windows is missing

[ https://issues.apache.org/jira/browse/KAFKA-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788100#comment-15788100 ] Vahid Hashemian commented on KAFKA-4572: [~aravindk47] This is already addressed i

[jira] [Created] (KAFKA-4577) NPE in ControllerChannelManager.scala::addUpdateMetadataRequestForBrokers

Scott Reynolds created KAFKA-4577: - Summary: NPE in ControllerChannelManager.scala::addUpdateMetadataRequestForBrokers Key: KAFKA-4577 URL: https://issues.apache.org/jira/browse/KAFKA-4577 Project: K

[jira] [Commented] (KAFKA-3297) More optimally balanced partition assignment strategy (new consumer)

[ https://issues.apache.org/jira/browse/KAFKA-3297?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788229#comment-15788229 ] Ewen Cheslack-Postava commented on KAFKA-3297: -- Yeah, part of the improvement

[jira] [Commented] (KAFKA-4572) Kafka connect for windows is missing

[ https://issues.apache.org/jira/browse/KAFKA-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788234#comment-15788234 ] Ewen Cheslack-Postava commented on KAFKA-4572: -- [~vahid] The version he inclu

Please add my wiki username contributor permission list

Hey devs, My jira username is aartigupta and my wiki username happens to be aartiguptaa (not sure how that happened) I already have JIRA access, but no permissions to edit the KIP wiki. https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Can someone grant my username

[jira] [Commented] (KAFKA-4572) Kafka connect for windows is missing

[ https://issues.apache.org/jira/browse/KAFKA-4572?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788258#comment-15788258 ] Vahid Hashemian commented on KAFKA-4572: [~ewencp] I'll take a closer look. Thanks

Re: [DISCUSS] KIP-66 Kafka Connect Transformers for messages

On Thu, Dec 15, 2016 at 7:41 PM, Shikhar Bhushan wrote: > There is no decision being proposed on the final list of transformations > that will ever be in Kafka :-) Just the initial set we should roll with. > I'd second this comment as well. I'm very wary of the slippery slope, which is why I was

Re: Please add my wiki username contributor permission list

I've granted you permissions, you should now be able to edit the main KIP page and add a new KIP. -Ewen On Fri, Dec 30, 2016 at 2:58 PM, Aarti Gupta wrote: > Hey devs, > > My jira username is aartigupta > and my wiki username happens to be aartiguptaa > (not sure how that happened) > > I alrea

[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=15788347#comment-15788347 ] Ewen Cheslack-Postava commented on KAFKA-4556: -- Can you be more specific abou

[jira] [Resolved] (KAFKA-4413) Kakfa should support default SSLContext

[ https://issues.apache.org/jira/browse/KAFKA-4413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wenjie Zhang resolved KAFKA-4413. - Resolution: Invalid It seems like Kafka does support it, closing this ticket as invalid. > Kakfa

[jira] [Commented] (KAFKA-4514) Add Codec for ZStandard Compression

[ https://issues.apache.org/jira/browse/KAFKA-4514?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788615#comment-15788615 ] Ewen Cheslack-Postava commented on KAFKA-4514: -- How broadly is zstd being ado

[jira] [Commented] (KAFKA-4550) current trunk unstable

[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788626#comment-15788626 ] Ewen Cheslack-Postava commented on KAFKA-4550: -- Seems like the second issue i

[jira] [Commented] (KAFKA-4550) current trunk unstable

[ https://issues.apache.org/jira/browse/KAFKA-4550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788627#comment-15788627 ] Ewen Cheslack-Postava commented on KAFKA-4550: -- One of the failures reported

[jira] [Commented] (KAFKA-3539) KafkaProducer.send() may block even though it returns the Future

[ https://issues.apache.org/jira/browse/KAFKA-3539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788664#comment-15788664 ] Ewen Cheslack-Postava commented on KAFKA-3539: -- http://mail-archives.apache.o

[jira] [Updated] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3135: - Affects Version/s: 0.10.1.0 0.9.0.1 0

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788677#comment-15788677 ] Ewen Cheslack-Postava commented on KAFKA-3135: -- [~jeffwidman] I've updated th

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788679#comment-15788679 ] Ewen Cheslack-Postava commented on KAFKA-3135: -- Also, /cc [~hachikuji] since

[jira] [Commented] (KAFKA-3856) Move inner classes accessible only functions in TopologyBuilder out of public APIs

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788683#comment-15788683 ] Ewen Cheslack-Postava commented on KAFKA-3856: -- [~mjsax] 6mo seems long enoug

[jira] [Updated] (KAFKA-3856) Move inner classes accessible only functions in TopologyBuilder out of public APIs

[ https://issues.apache.org/jira/browse/KAFKA-3856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3856: - Assignee: Matthias J. Sax (was: Jeyhun Karimov) > Move inner classes accessible o

[jira] [Commented] (KAFKA-3135) Unexpected delay before fetch response transmission

[ https://issues.apache.org/jira/browse/KAFKA-3135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788686#comment-15788686 ] Jeff Widman commented on KAFKA-3135: It's not currently a critical issue for my compan

[jira] [Commented] (KAFKA-4531) Rationalise client configuration validation

[ https://issues.apache.org/jira/browse/KAFKA-4531?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788707#comment-15788707 ] Ewen Cheslack-Postava commented on KAFKA-4531: -- Could we bake this into {{Con

[jira] [Resolved] (KAFKA-4530) cant stop kafka server

[ https://issues.apache.org/jira/browse/KAFKA-4530?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-4530. -- Resolution: Duplicate Assignee: Ewen Cheslack-Postava > cant stop kafka se

[jira] [Commented] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788842#comment-15788842 ] Ewen Cheslack-Postava commented on KAFKA-4517: -- Upgraded to blocker for 0.11.

[jira] [Updated] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4517: - Fix Version/s: 0.11.0.0 > Remove kafka-consumer-offset-checker.sh script since alr

[jira] [Updated] (KAFKA-4517) Remove kafka-consumer-offset-checker.sh script since already deprecated in Kafka 9

[ https://issues.apache.org/jira/browse/KAFKA-4517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-4517: - Priority: Blocker (was: Minor) > Remove kafka-consumer-offset-checker.sh script s

[jira] [Commented] (KAFKA-4519) Delete old unused branches in git repo

[ https://issues.apache.org/jira/browse/KAFKA-4519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15788849#comment-15788849 ] Ewen Cheslack-Postava commented on KAFKA-4519: -- There are probably more of th

[DISCUSS] KIP-104: Granular Sensors for Streams

Hi all, I would like to start the discussion on KIP-104: Granular Sensors for Streams *https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=67636480

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

Hi all, I would like to start the discussion on KIP-105: Addition of Record Level for Sensors *https://cwiki.apache.org/confluence/pages/viewpage.action? * *pageId=67636483* Looking forward to your feedback. Thanks, Aarti

Re: Please add my wiki username contributor permission list

Thanks Ewen! I was able to edit the page and add two new KIPs Aarti On Fri, Dec 30, 2016 at 12:47 PM, Ewen Cheslack-Postava wrote: > I've granted you permissions, you should now be able to edit the main KIP > page and add a new KIP. > > -Ewen > > On Fri, Dec 30, 2016 at 2:58 PM, Aarti Gupta >