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

See Changes: [wangguoz] KAFKA-3430: Allow users to set key in KTable.toStream and in KStream. -- [...truncated 2485 lines...] kafka.api.ProducerFailureHandlingTest > testNotEnoughReplicas PASSED

Re: [VOTE] KIP-33 - Add a time based log index

+1 On Fri, Apr 15, 2016 at 9:37 AM, Guozhang Wang wrote: > +1 from me. Thanks. > > On Fri, Apr 15, 2016 at 9:16 AM, Jun Rao wrote: > >> Hi, Jiangjie, >> >> Thanks for the latest update. +1 on the KIP. >> >> Jun >> >> On Thu, Apr 14, 2016 at 2:36 PM, Becket Qin wrote: >> >> > Hi Jun, >> > >> > 1

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

See Changes: [wangguoz] KAFKA-3430: Allow users to set key in KTable.toStream and in KStream. -- [...truncated 1603 lines...] kafka.log.OffsetIndexTest > appendTooMany PASSED kafka.log.OffsetI

[jira] [Commented] (KAFKA-3523) Capture org.apache.kafka.clients.consumer.CommitFailedException in UncaughtExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15244520#comment-15244520 ] Guozhang Wang commented on KAFKA-3523: -- Closing as this turns out not an issue, while

[jira] [Resolved] (KAFKA-3523) Capture org.apache.kafka.clients.consumer.CommitFailedException in UncaughtExceptionHandler

[ https://issues.apache.org/jira/browse/KAFKA-3523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3523. -- Resolution: Not A Problem > Capture org.apache.kafka.clients.consumer.CommitFailedException in

[jira] [Commented] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

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

[jira] [Updated] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream

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

[GitHub] kafka pull request: KAFKA-3430: Allow users to set key in KTable.t...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1222 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enab

[jira] [Commented] (KAFKA-3529) Transient kafka.api.PlaintextConsumerTest.testAsyncCommit failures

[ https://issues.apache.org/jira/browse/KAFKA-3529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15244513#comment-15244513 ] Guozhang Wang commented on KAFKA-3529: -- Saw another example of this failure: https:/

[jira] [Assigned] (KAFKA-3571) Traits for utilities like ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Liquan Pei reassigned KAFKA-3571: - Assignee: Liquan Pei > Traits for utilities like ConsumerGroupCommand > -

[jira] [Commented] (KAFKA-3571) Traits for utilities like ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15244359#comment-15244359 ] Ismael Juma commented on KAFKA-3571: I think KIP-4 may be a better way to do this. >

kafka streaming: passing config string to Processor

Hello, I'm implementing yahoo streaming benchmark with Kafka streaming processing. How to pass a string into Processor or ValueTransformer instance? Accordingly to yahoo benchmark logic I need to transfer an address of Redis server. https://github.com/rssdev10/streaming-benchmarks/blob/master/ka

[jira] [Updated] (KAFKA-3571) Traits for utilities like ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3571?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Zoller updated KAFKA-3571: --- Issue Type: Improvement (was: New Feature) > Traits for utilities like ConsumerGroupCommand > ---

[jira] [Created] (KAFKA-3571) Traits for utilities like ConsumerGroupCommand

Greg Zoller created KAFKA-3571: -- Summary: Traits for utilities like ConsumerGroupCommand Key: KAFKA-3571 URL: https://issues.apache.org/jira/browse/KAFKA-3571 Project: Kafka Issue Type: New Feat

[jira] [Created] (KAFKA-3570) It'd be nice to line up display output in columns in ConsumerGroupCommand

Greg Zoller created KAFKA-3570: -- Summary: It'd be nice to line up display output in columns in ConsumerGroupCommand Key: KAFKA-3570 URL: https://issues.apache.org/jira/browse/KAFKA-3570 Project: Kafka

[jira] [Created] (KAFKA-3569) commitAsync() sometimes fails with errors

Greg Zoller created KAFKA-3569: -- Summary: commitAsync() sometimes fails with errors Key: KAFKA-3569 URL: https://issues.apache.org/jira/browse/KAFKA-3569 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-3569) commitAsync() sometimes fails with errors

[ https://issues.apache.org/jira/browse/KAFKA-3569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Zoller updated KAFKA-3569: --- Description: I have a KafkaConsumer instance I've wrapped in a thread, which communicates with the ou

[jira] [Created] (KAFKA-3568) KafkaProducer fails with timeout on message send()

Greg Zoller created KAFKA-3568: -- Summary: KafkaProducer fails with timeout on message send() Key: KAFKA-3568 URL: https://issues.apache.org/jira/browse/KAFKA-3568 Project: Kafka Issue Type: Bug

Re: [RELEASE] Anyone minds if we push the next RC another week away?

+1 > On Apr 15, 2016, at 11:20 AM, Harsha wrote: > > +1 > >> On Fri, Apr 15, 2016, at 08:06 AM, Grant Henke wrote: >> +1 >> >> On Fri, Apr 15, 2016 at 10:05 AM, Ashish Singh >> wrote: >> >>> Good idea. Thanks! >>> On Friday, April 15, 2016, Ismael Juma wrote: +1

Re: Reg: Kafka With Kerberos/SSL [Enhancement to add option, Need suggestions on this]

Bharat, Here is the jira https://issues.apache.org/jira/browse/KAFKA-3567 -Harsha On Thu, Apr 14, 2016, at 10:29 AM, BigData dev wrote: > Hi All, > When Kafka is running on kerberoized cluster/ SSL. Can we add an option > security.protocol. So, that user can given PLAINTE

[jira] [Created] (KAFKA-3567) Add --security-protocol option console tools

Sriharsha Chintalapani created KAFKA-3567: - Summary: Add --security-protocol option console tools Key: KAFKA-3567 URL: https://issues.apache.org/jira/browse/KAFKA-3567 Project: Kafka

Re: Reg: Issue with Kafka Kerberos (Kafka Version 0.9.0.1)

Bharat, Did you add super.users=user:kafka to your server.properties. -Harsha On Tue, Apr 12, 2016, at 05:07 PM, BigData dev wrote: > Hi All, > I am facing issue with kafka kerberoized cluster. > > After following the steps how to enables SASL on kafka by using below

[jira] [Resolved] (KAFKA-3342) https://cwiki.apache.org/confluence/display/KAFKA/Log+Compaction has log.cleaner.min.cleanable.ratio listed twice in error

[ https://issues.apache.org/jira/browse/KAFKA-3342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-3342. Resolution: Fixed Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 Updated

[jira] [Updated] (KAFKA-3406) CommonClientConfigs.RETRY_BACKOFF_MS_DOC should be more general

[ https://issues.apache.org/jira/browse/KAFKA-3406?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-3406: --- Assignee: Manikumar Reddy Fix Version/s: 0.10.0.0 Status: Patch Available

[jira] [Commented] (KAFKA-3406) CommonClientConfigs.RETRY_BACKOFF_MS_DOC should be more general

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

[GitHub] kafka pull request: KAFKA-3406; Update CommonClientConfigs.RETRY_B...

GitHub user omkreddy opened a pull request: https://github.com/apache/kafka/pull/1230 KAFKA-3406; Update CommonClientConfigs.RETRY_BACKOFF_MS_DOC doc string You can merge this pull request into a Git repository by running: $ git pull https://github.com/omkreddy/kafka KAFKA-340

[jira] [Resolved] (KAFKA-2181) online doc issues

[ https://issues.apache.org/jira/browse/KAFKA-2181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-2181. Resolution: Fixed Fix Version/s: 0.10.0.0 These minor doc corrections are updated on

[jira] [Resolved] (KAFKA-869) Java API needs Encoder / Decoder interfaces

[ https://issues.apache.org/jira/browse/KAFKA-869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-869. --- Resolution: Won't Fix This issue not exists in new java client classes. > Java API needs Encod