[jira] [Updated] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

[ https://issues.apache.org/jira/browse/KAFKA-3011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Eric Bowman updated KAFKA-3011: --- Description: Because of this loop in ConsumerNetworkClient: {code:java} public void awaitMetadata

[jira] [Created] (KAFKA-3011) Consumer.poll(0) blocks if Kafka not accessible

Eric Bowman created KAFKA-3011: -- Summary: Consumer.poll(0) blocks if Kafka not accessible Key: KAFKA-3011 URL: https://issues.apache.org/jira/browse/KAFKA-3011 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request: KAFKA-2875: remove slf4j multi binding warning...

GitHub user ZoneMayor opened a pull request: https://github.com/apache/kafka/pull/693 KAFKA-2875: remove slf4j multi binding warnings when running form source distribution hi @ijuma I reopened this pr again (sorry for my inexperience using github); I think I did much deduplicat

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

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

[GitHub] kafka pull request: KAFKA-2875: Class path contains multiple SLF4J...

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

[jira] [Commented] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

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

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063589#comment-15063589 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- I'm open to fixing the PR bot

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

See

[jira] [Created] (KAFKA-3010) include error code when logging an error when ack = 0

Jun Rao created KAFKA-3010: -- Summary: include error code when logging an error when ack = 0 Key: KAFKA-3010 URL: https://issues.apache.org/jira/browse/KAFKA-3010 Project: Kafka Issue Type: Improveme

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

See

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker Ubuntu ubuntu ubuntu1) in workspace

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

See Changes: [cshapi] MINOR: Fix broken documentation link -- [...truncated 2821 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanShutdownFile PASSED kafka.log.

[jira] [Created] (KAFKA-3009) Disallow star imports

Gwen Shapira created KAFKA-3009: --- Summary: Disallow star imports Key: KAFKA-3009 URL: https://issues.apache.org/jira/browse/KAFKA-3009 Project: Kafka Issue Type: Bug Reporter: Gwen

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

See -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-1 (docker Ubuntu ubuntu ubuntu1) in workspace

[jira] [Resolved] (KAFKA-2964) Split Security Rolling Upgrade Test By Client and Broker Protocols

[ https://issues.apache.org/jira/browse/KAFKA-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2964. - Resolution: Fixed Fix Version/s: 0.9.1.0 Issue resolved by pull request 667 [https://github

[jira] [Commented] (KAFKA-2964) Split Security Rolling Upgrade Test By Client and Broker Protocols

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

[jira] [Updated] (KAFKA-2964) Split Security Rolling Upgrade Test By Client and Broker Protocols

[ https://issues.apache.org/jira/browse/KAFKA-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2964: Assignee: Ben Stopford > Split Security Rolling Upgrade Test By Client and Broker Protocols > --

[GitHub] kafka pull request: KAFKA-2964: Split Security Rolling Upgrade Tes...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/667 --- 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-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063255#comment-15063255 ] Ismael Juma commented on KAFKA-3006: That's right, it's not binary compatible, which c

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063240#comment-15063240 ] Jason Gustafson commented on KAFKA-3006: [~ijuma] I agree that it's source-compati

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063224#comment-15063224 ] Gwen Shapira commented on KAFKA-3006: - +1 on fixing this before more people adopt the

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

See Changes: [cshapi] MINOR: Fix broken documentation link -- Started by an SCM change [EnvInject] - Loading node environment variables. Building remotely on ubuntu-2 (docker Ubuntu ubuntu) in wo

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063220#comment-15063220 ] Ismael Juma commented on KAFKA-3006: cc [~ewencp] > Make collection default container

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063218#comment-15063218 ] Ismael Juma commented on KAFKA-3006: I agree that there is value in maintaining compat

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063203#comment-15063203 ] Ismael Juma commented on KAFKA-3006: Ag > Make collection default container type for

[jira] [Issue Comment Deleted] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-3006: --- Comment: was deleted (was: Ag) > Make collection default container type for sequences in the consumer

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063200#comment-15063200 ] Jason Gustafson commented on KAFKA-3006: Argh. I'm kicking myself for not fixing t

[GitHub] kafka pull request: MINOR: Fix broken documentation link

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/692 --- 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-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063183#comment-15063183 ] Ismael Juma commented on KAFKA-3006: I am not sure about the value of having methods f

[GitHub] kafka pull request: MINOR: Fix broken documentation link

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/692 MINOR: Fix broken documentation link The link to 'Producer Configs' section of the documentation is updated with this PR. You can merge this pull request into a Git repository by running:

[GitHub] kafka pull request: MINOR: Fix broken documentation link

Github user vahidhashemian closed the pull request at: https://github.com/apache/kafka/pull/692 --- 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-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063165#comment-15063165 ] Jason Gustafson commented on KAFKA-3006: As a user, I would appreciate being able

[jira] [Commented] (KAFKA-2988) Change default configuration of the log cleaner

[ https://issues.apache.org/jira/browse/KAFKA-2988?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063155#comment-15063155 ] Ismael Juma commented on KAFKA-2988: We should also consider backporting this to the 0

[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=15063151#comment-15063151 ] Jason Gustafson commented on KAFKA-2887: [~mgharat] Yes, that is what I meant. I w

[jira] [Commented] (KAFKA-2940) Make available to use any Java options at startup scripts

[ https://issues.apache.org/jira/browse/KAFKA-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063146#comment-15063146 ] Ismael Juma commented on KAFKA-2940: Thanks. > Make available to use any Java options

[jira] [Resolved] (KAFKA-794) Clean up controller logging

[ https://issues.apache.org/jira/browse/KAFKA-794?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-794. Resolution: Won't Fix Kinda old now :) Lets celebrate 3rd birthday by closing. We can create a new J

[jira] [Resolved] (KAFKA-2940) Make available to use any Java options at startup scripts

[ https://issues.apache.org/jira/browse/KAFKA-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sasaki Toru resolved KAFKA-2940. Resolution: Not A Problem > Make available to use any Java options at startup scripts >

[jira] [Resolved] (KAFKA-598) decouple fetch size from max message size

[ https://issues.apache.org/jira/browse/KAFKA-598?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-598. Resolution: Won't Fix If we didn't fix it for the last 3 years... > decouple fetch size from max mes

[jira] [Comment Edited] (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=15063131#comment-15063131 ] Mayuresh Gharat edited comment on KAFKA-2887 at 12/18/15 12:02 AM: -

[jira] [Commented] (KAFKA-2940) Make available to use any Java options at startup scripts

[ https://issues.apache.org/jira/browse/KAFKA-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063133#comment-15063133 ] Sasaki Toru commented on KAFKA-2940: Thanks for comments, [[~ijuma]. KAFKA_OPTS is so

[jira] [Comment Edited] (KAFKA-2940) Make available to use any Java options at startup scripts

[ https://issues.apache.org/jira/browse/KAFKA-2940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063133#comment-15063133 ] Sasaki Toru edited comment on KAFKA-2940 at 12/18/15 12:03 AM: -

[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=15063131#comment-15063131 ] Mayuresh Gharat commented on KAFKA-2887: [~hachikuji] just wanted to be sure what

[jira] [Updated] (KAFKA-1843) Metadata fetch/refresh in new producer should handle all node connection states gracefully

[ https://issues.apache.org/jira/browse/KAFKA-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-1843: Status: Open (was: Patch Available) Patch is no longer available but there is still work to be done

[jira] [Commented] (KAFKA-2940) Make available to use any Java options at startup scripts

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

[jira] [Resolved] (KAFKA-2038) Unable to restart brokers after it went down with no space left on disk

[ https://issues.apache.org/jira/browse/KAFKA-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2038. - Resolution: Won't Fix > Unable to restart brokers after it went down with no space left on disk >

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063121#comment-15063121 ] Jay Kreps commented on KAFKA-3006: -- Hmm, does it make sense to do it both ways? I get tha

[GitHub] kafka pull request: KAFKA-2940: Make available to use any Java opt...

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

[jira] [Commented] (KAFKA-2038) Unable to restart brokers after it went down with no space left on disk

[ https://issues.apache.org/jira/browse/KAFKA-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063122#comment-15063122 ] Gwen Shapira commented on KAFKA-2038: - You can use RAID 0 to create one large director

[jira] [Comment Edited] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063110#comment-15063110 ] Gwen Shapira edited comment on KAFKA-3004 at 12/17/15 11:47 PM:

[jira] [Resolved] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-3004. - Resolution: Won't Fix > Brokers failing over repeatadly > --- > >

[jira] [Commented] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063110#comment-15063110 ] Gwen Shapira commented on KAFKA-3004: - Possibly long GC pauses cause Kafka to lose the

[jira] [Resolved] (KAFKA-2125) Infinite loop after controlled shutdown succeeds

[ https://issues.apache.org/jira/browse/KAFKA-2125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira resolved KAFKA-2125. - Resolution: Cannot Reproduce Closing this since we think this is resolved in trunk. > Infinite lo

[jira] [Commented] (KAFKA-2634) KafkaProducer hangs on future.get()

[ https://issues.apache.org/jira/browse/KAFKA-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063087#comment-15063087 ] Gwen Shapira commented on KAFKA-2634: - Actually we are doing a bit better than no deta

[jira] [Commented] (KAFKA-2634) KafkaProducer hangs on future.get()

[ https://issues.apache.org/jira/browse/KAFKA-2634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063078#comment-15063078 ] Gwen Shapira commented on KAFKA-2634: - Can you try the second test-case on 0.9.0 relea

[jira] [Updated] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed one of more brokers will un-register/register almost every

[jira] [Updated] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Summary: Brokers failing over repeatadly (was: Controller failing over repeatadly) > Brokers failing over repeat

[jira] [Updated] (KAFKA-3004) Brokers failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Component/s: network > Brokers failing over repeatadly > --- > > Key:

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15063016#comment-15063016 ] Jason Gustafson commented on KAFKA-3007: Ok, that makes sense. Keep in mind that y

[jira] [Comment Edited] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062996#comment-15062996 ] aarti gupta edited comment on KAFKA-3007 at 12/17/15 10:44 PM: -

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062996#comment-15062996 ] aarti gupta commented on KAFKA-3007: The concern is, that in the scenario in which I h

[jira] [Updated] (KAFKA-3007) new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessageLimit)

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] aarti gupta updated KAFKA-3007: --- Summary: new Consumer should expose mechanism to fetch single message, consumer.poll(timeout, maxMessa

[GitHub] kafka pull request: MINOR: Fix Broken Documentation Link

GitHub user vahidhashemian opened a pull request: https://github.com/apache/kafka/pull/692 MINOR: Fix Broken Documentation Link The link to 'Producer Configs' section of the documentation is updated with this PR. You can merge this pull request into a Git repository by running:

[jira] [Updated] (KAFKA-3008) Connect should parallelize task start/stop

[ https://issues.apache.org/jira/browse/KAFKA-3008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-3008: - Assignee: Liquan Pei (was: Ewen Cheslack-Postava) > Connect should parallelize ta

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062931#comment-15062931 ] Jason Gustafson commented on KAFKA-3007: The internal method pollOnce is probably

[jira] [Created] (KAFKA-3008) Connect should parallelize task start/stop

Ewen Cheslack-Postava created KAFKA-3008: Summary: Connect should parallelize task start/stop Key: KAFKA-3008 URL: https://issues.apache.org/jira/browse/KAFKA-3008 Project: Kafka Issu

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062904#comment-15062904 ] aarti gupta commented on KAFKA-3007: Is this on the dev mailing list? If so, please ca

[jira] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pierre-Yves Ritschard updated KAFKA-3006: - Description: The KafkaConsumer API has some annoying inconsistencies in the usage

[jira] [Resolved] (KAFKA-2991) Improve collection type consistency in KafkaConsumer API

[ https://issues.apache.org/jira/browse/KAFKA-2991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-2991. Resolution: Duplicate There's already a patch available in KAFKA-3006, so resolving as dupli

[jira] [Commented] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062854#comment-15062854 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- @jason gustafson I updated th

[jira] [Updated] (KAFKA-3006) Make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pierre-Yves Ritschard updated KAFKA-3006: - Summary: Make collection default container type for sequences in the consumer API

[jira] [Updated] (KAFKA-3006) make collection default container type for sequences in the consumer API

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pierre-Yves Ritschard updated KAFKA-3006: - Summary: make collection default container type for sequences in the consumer API

[jira] [Updated] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Pierre-Yves Ritschard updated KAFKA-3006: - Description: The KafkaConsumer API has some annoying inconsistencies in the usage

[jira] [Commented] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062827#comment-15062827 ] Jason Gustafson commented on KAFKA-3006: [~pyritschard] IMO, keeping the current m

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062811#comment-15062811 ] Jason Gustafson commented on KAFKA-3007: [~aartigupta] We've been talking on the u

[jira] [Commented] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062799#comment-15062799 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- [~hachikuji] I added the nece

[jira] [Commented] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

[ https://issues.apache.org/jira/browse/KAFKA-3007?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062742#comment-15062742 ] aarti gupta commented on KAFKA-3007: Can we expose the following private api as a publ

[jira] [Created] (KAFKA-3007) new Consumer should expose mechanism to fetch single message

aarti gupta created KAFKA-3007: -- Summary: new Consumer should expose mechanism to fetch single message Key: KAFKA-3007 URL: https://issues.apache.org/jira/browse/KAFKA-3007 Project: Kafka Issu

[jira] [Commented] (KAFKA-2653) Stateful operations in the KStream DSL layer

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

[jira] [Commented] (KAFKA-2653) Stateful operations in the KStream DSL layer

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

[GitHub] kafka pull request: KAFKA-2653: Kafka Streams Stateful API Design

GitHub user guozhangwang opened a pull request: https://github.com/apache/kafka/pull/691 KAFKA-2653: Kafka Streams Stateful API Design You can merge this pull request into a Git repository by running: $ git pull https://github.com/guozhangwang/kafka K2653 Alternatively you ca

[GitHub] kafka pull request: KAFKA-2653 Phase I: Stateful Operation API Des...

Github user guozhangwang closed the pull request at: https://github.com/apache/kafka/pull/665 --- 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-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062599#comment-15062599 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- [~hachikuji] Hi Jason, I'm ha

[jira] [Commented] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062613#comment-15062613 ] Pierre-Yves Ritschard commented on KAFKA-3006: -- [~hachikuji] Yes will do so i

[jira] [Commented] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062604#comment-15062604 ] Jason Gustafson commented on KAFKA-3006: [~pyritschard] Works for me. Want to chan

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062547#comment-15062547 ] Sriharsha Chintalapani commented on KAFKA-2000: --- [~ijuma] Yes. > Delete con

[jira] [Commented] (KAFKA-2836) FAILING TEST: SaslSslTopicMetadataTest

[ https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062501#comment-15062501 ] Bill Bejeck commented on KAFKA-2836: Picking this bug up. > FAILING TEST: SaslSslTopi

[jira] [Assigned] (KAFKA-2836) FAILING TEST: SaslSslTopicMetadataTest

[ https://issues.apache.org/jira/browse/KAFKA-2836?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck reassigned KAFKA-2836: -- Assignee: Bill Bejeck > FAILING TEST: SaslSslTopicMetadataTest > --

[jira] [Commented] (KAFKA-3006) kafka client should offer Collection alternative to Array call signatures

[ https://issues.apache.org/jira/browse/KAFKA-3006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062473#comment-15062473 ] Jason Gustafson commented on KAFKA-3006: [~pyritschard] This has some overlap with

Request for additions to Ecosystems and Clients pages

Hi, Is it possible to get IBM Message Hub added to the Ecosystems page. I'd imagine that the right place would be in Distributions and Packaging, although if you think that there's a better heading for it to go under, that's fine. Message Hub is a fully managed service, built on Kafka. It is

[jira] [Commented] (KAFKA-1860) File system errors are not detected unless Kafka tries to write

[ https://issues.apache.org/jira/browse/KAFKA-1860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062409#comment-15062409 ] Mayuresh Gharat commented on KAFKA-1860: Cool. > File system errors are not detec

[jira] [Resolved] (KAFKA-95) Create Jenkins readable test output

[ https://issues.apache.org/jira/browse/KAFKA-95?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-95. -- Resolution: Fixed Fix Version/s: (was: 0.10.0.0) 0.9.0.0 > Create Jenkins re

[jira] [Commented] (KAFKA-95) Create Jenkins readable test output

[ https://issues.apache.org/jira/browse/KAFKA-95?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062399#comment-15062399 ] Ismael Juma commented on KAFKA-95: -- This was fixed a while back: https://builds.apache.org

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

[jira] [Commented] (KAFKA-1860) File system errors are not detected unless Kafka tries to write

[ https://issues.apache.org/jira/browse/KAFKA-1860?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062380#comment-15062380 ] Ismael Juma commented on KAFKA-1860: Maybe worth filing a PR with this change. > File

[jira] [Commented] (KAFKA-2000) Delete consumer offsets from kafka once the topic is deleted

[ https://issues.apache.org/jira/browse/KAFKA-2000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15062369#comment-15062369 ] Ismael Juma commented on KAFKA-2000: Looks like it is, `GroupMetadataManager` has the

[jira] [Updated] (KAFKA-3004) Controller failing over repeatadly

[ https://issues.apache.org/jira/browse/KAFKA-3004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sadek updated KAFKA-3004: - Description: While doing load testing we have noticed that the controller will fail over almost every hour with t

  1   2   >