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

See Changes: [wangguoz] KAFKA-4058: Failure in -- [...truncated 12243 lines...] org.apache.kafka.streams.kstream.internals.KTableFilterTest > testSkipNullOnMaterialization PASSED org.apache.kaf

Re: [ANNOUNCE] New committer: Jason Gustafson

Congrats, Jason. Well done and great to see this project inviting new committers. -Flavio On 7 Sep 2016 04:58, "Ashish Singh" wrote: > Congrats, Jason! > > On Tuesday, September 6, 2016, Jason Gustafson wrote: > > > Thanks all! > > > > On Tue, Sep 6, 2016 at 5:13 PM, Becket Qin > > wrote: > >

[jira] [Commented] (KAFKA-4111) broker compress data of certain size instead on a produce request

[ https://issues.apache.org/jira/browse/KAFKA-4111?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15469890#comment-15469890 ] julien1987 commented on KAFKA-4111: --- Thanks.On our scene, message qps of every producer

[GitHub] kafka pull request #1830: [WIP] KIP-78 : Cluster Identifier (KAFKA-4093)

GitHub user arrawatia opened a pull request: https://github.com/apache/kafka/pull/1830 [WIP] KIP-78 : Cluster Identifier (KAFKA-4093) This is a first draft that includes the following changes: 1. Changes to the broker code. - generation of cluster id and storing it in Zook

[jira] [Created] (KAFKA-4138) Producer data write network traffic to kafka brokers is increased for 50%

Zane Zhang created KAFKA-4138: - Summary: Producer data write network traffic to kafka brokers is increased for 50% Key: KAFKA-4138 URL: https://issues.apache.org/jira/browse/KAFKA-4138 Project: Kafka

[GitHub] kafka pull request #1817: KAFKA-3703: Flush outgoing writes before closing c...

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

Re: [DISCUSS] Time-based releases for Apache Kafka

Thanks for volunteering Jason. Sounds good to me, Ismael On Wed, Sep 7, 2016 at 4:22 AM, Jason Gustafson wrote: > Hey All, > > It sounds like the general consensus is in favor of time-based releases. We > can continue the discussion about LTS, but I wanted to go ahead and get > things moving fo

[jira] [Commented] (KAFKA-3703) Selector.close() doesn't complete outgoing writes

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

Re: [ANNOUNCE] New committer: Jason Gustafson

Congrats, Jason! On Wed, Sep 7, 2016 at 8:29 AM, Flavio P JUNQUEIRA wrote: > Congrats, Jason. Well done and great to see this project inviting new > committers. > > -Flavio > > On 7 Sep 2016 04:58, "Ashish Singh" wrote: > > > Congrats, Jason! > > > > On Tuesday, September 6, 2016, Jason Gustafs

dev@kafka.apache.org

[ https://issues.apache.org/jira/browse/KAFKA-4119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470107#comment-15470107 ] Rajini Sivaram commented on KAFKA-4119: --- Only the new consumer supports security. So

[jira] [Created] (KAFKA-4139) Kafka consumer stuck in ensureCoordinatorReady after broker failure

Rajini Sivaram created KAFKA-4139: - Summary: Kafka consumer stuck in ensureCoordinatorReady after broker failure Key: KAFKA-4139 URL: https://issues.apache.org/jira/browse/KAFKA-4139 Project: Kafka

[DISCUSS] KIP-68 Add a consumed log retention before log retention

Hi All, I have made a KIP to enhance the log retention, details as follows: https://cwiki.apache.org/confluence/display/KAFKA/KIP-68+Add+a+consumed+log+retention+before+log+retention Now start a discuss thread for this KIP , looking forward to the feedback. Thanks, David

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

See Changes: [wangguoz] KAFKA-4058: Failure in -- [...truncated 6092 lines...] kafka.log.FileMessageSetTest > testFileSize STARTED kafka.log.FileMessageSetTest > testFileSize PASSED kafka.log.

[GitHub] kafka pull request #1831: KAFKA-4139: Reset findCoordinatorFuture when broke...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/1831 KAFKA-4139: Reset findCoordinatorFuture when brokers are unavailable You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka K

[jira] [Commented] (KAFKA-4139) Kafka consumer stuck in ensureCoordinatorReady after broker failure

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

[jira] [Updated] (KAFKA-4139) Kafka consumer stuck in ensureCoordinatorReady after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-4139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram updated KAFKA-4139: -- Status: Patch Available (was: Open) > Kafka consumer stuck in ensureCoordinatorReady after brok

[jira] [Updated] (KAFKA-4034) Consumer need not lookup coordinator when using manual assignment

[ https://issues.apache.org/jira/browse/KAFKA-4034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4034: --- Resolution: Fixed Status: Resolved (was: Patch Available) > Consumer need not lookup coordina

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1 (non-binding) On Wed, Sep 7, 2016 at 4:09 AM, Sriram Subramanian wrote: > +1 binding > > > On Sep 6, 2016, at 7:46 PM, Ismael Juma wrote: > > > > Hi all, > > > > I would like to (re)initiate[1] the voting process for KIP-78 Cluster Id: > > > > https://cwiki.apache.org/confluence/display/KAFK

[jira] [Commented] (KAFKA-451) follower replica may need to backoff the fetching if leader is not ready yet

[ https://issues.apache.org/jira/browse/KAFKA-451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470408#comment-15470408 ] Ismael Juma commented on KAFKA-451: --- We have the following code in AbstractFetcherThread:

[jira] [Commented] (KAFKA-4137) Refactor multi-threaded consumer for safer network layer access

[ https://issues.apache.org/jira/browse/KAFKA-4137?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15470445#comment-15470445 ] Ismael Juma commented on KAFKA-4137: KAFKA-1935 may be a duplicate of this one (with l

Re: [ANNOUNCE] New committer: Jason Gustafson

Congrats Jason! Eno > On 7 Sep 2016, at 10:00, Rajini Sivaram wrote: > > Congrats, Jason! > > On Wed, Sep 7, 2016 at 8:29 AM, Flavio P JUNQUEIRA wrote: > >> Congrats, Jason. Well done and great to see this project inviting new >> committers. >> >> -Flavio >> >> On 7 Sep 2016 04:58, "Ashish

[GitHub] kafka pull request #1832: MINOR: Document that Connect topics should use com...

GitHub user mfenniak opened a pull request: https://github.com/apache/kafka/pull/1832 MINOR: Document that Connect topics should use compaction Update documentation for Kafka Connect distributed’s config.storage.topic, offset.storage.topic, and status.storage.topic configuration

Re: [DISCUSS] KIP-63: Unify store and downstream caching in streams

Gouzhang, Some points about what you have mentioned: 1. You can't just call context.forward() on the flush listener. You have to set some other contextual information (currently ProcessorRecordContext) prior to doing this otherwise the nodes you are forwarding to are undetermined, i.e, this can be

Re: [ANNOUNCE] New committer: Jason Gustafson

congrats Jason ! Thanks, Mayuresh On Wed, Sep 7, 2016 at 5:16 AM, Eno Thereska wrote: > Congrats Jason! > > Eno > > On 7 Sep 2016, at 10:00, Rajini Sivaram > wrote: > > > > Congrats, Jason! > > > > On Wed, Sep 7, 2016 at 8:29 AM, Flavio P JUNQUEIRA > wrote: > > > >> Congrats, Jason. Well don

[GitHub] kafka pull request #1833: MINOR: fix transient QueryableStateIntegration tes...

GitHub user dguy opened a pull request: https://github.com/apache/kafka/pull/1833 MINOR: fix transient QueryableStateIntegration test failure The verification in verifyGreaterOrEqual was incorrect. It was failing when a new key was found. Set the TimeWindow to a large value so a

[GitHub] kafka pull request #1795: KAFKA-3129: Console producer issue when request-re...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1795 --- 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-3129) Console producer issue when request-required-acks=0

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

Re: [ANNOUNCE] New committer: Jason Gustafson

Congratulations and thank you for all of your contributions to Apache Kafka Jason! On Wed, Sep 7, 2016 at 10:12 AM, Mayuresh Gharat wrote: > congrats Jason ! > > Thanks, > > Mayuresh > > On Wed, Sep 7, 2016 at 5:16 AM, Eno Thereska > wrote: > > > Congrats Jason! > > > > Eno > > > On 7 Sep 2016,

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1 (non-binding) On Wed, Sep 7, 2016 at 6:55 AM, Rajini Sivaram wrote: > +1 (non-binding) > > On Wed, Sep 7, 2016 at 4:09 AM, Sriram Subramanian > wrote: > > > +1 binding > > > > > On Sep 6, 2016, at 7:46 PM, Ismael Juma wrote: > > > > > > Hi all, > > > > > > I would like to (re)initiate[1] th

Re: [DISCUSS] KIP-79 - ListOffsetRequest v1 and offsetForTime() method in new consumer.

Thanks everyone for all the feedback. If there is no further concerns or comments I will start a voting thread on this KIP tomorrow. Thanks, Jiangjie (Becket) Qin On Tue, Sep 6, 2016 at 9:48 AM, Becket Qin wrote: > Hi Magnus, > > Thanks for the comments. I agree that querying messages within

[jira] [Resolved] (KAFKA-3129) Console producer issue when request-required-acks=0

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dustin Cote resolved KAFKA-3129. Resolution: Fixed > Console producer issue when request-required-acks=0 > --

[jira] [Reopened] (KAFKA-3129) Console producer issue when request-required-acks=0

[ https://issues.apache.org/jira/browse/KAFKA-3129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dustin Cote reopened KAFKA-3129: Reopening per [~ijuma]'s recommendation as acks=0 in general still has a problem somewhere along the wa

[jira] [Assigned] (KAFKA-4135) Inconsistent javadoc for KafkaConsumer.poll behavior when there is no subscription

[ https://issues.apache.org/jira/browse/KAFKA-4135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vahid Hashemian reassigned KAFKA-4135: -- Assignee: Vahid Hashemian > Inconsistent javadoc for KafkaConsumer.poll behavior when t

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

See Changes: [ismael] KAFKA-3129; Console producer issue when request-required-acks=0 -- [...truncated 3469 lines...] kafka.coordinator.GroupMetadataManagerTest > testStoreNonEmptyGroup STARTED

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1 (binding) On Wed, Sep 7, 2016 at 9:49 AM Grant Henke wrote: > +1 (non-binding) > > On Wed, Sep 7, 2016 at 6:55 AM, Rajini Sivaram < > rajinisiva...@googlemail.com > > wrote: > > > +1 (non-binding) > > > > On Wed, Sep 7, 2016 at 4:09 AM, Sriram Subramanian > > wrote: > > > > > +1 binding > >

Re: [DISCUSS] Time-based releases for Apache Kafka

Thanks for volunteering, Jason! On Wed, Sep 7, 2016 at 1:59 AM Ismael Juma wrote: > Thanks for volunteering Jason. Sounds good to me, > > Ismael > > On Wed, Sep 7, 2016 at 4:22 AM, Jason Gustafson > wrote: > > > Hey All, > > > > It sounds like the general consensus is in favor of time-based rel

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

See Changes: [ismael] KAFKA-3129; Console producer issue when request-required-acks=0 -- [...truncated 12204 lines...] org.apache.kafka.streams.kstream.internals.KTableFilterTest > testSkipNull

Re: [DISCUSS] KIP-79 - ListOffsetRequest v1 and offsetForTime() method in new consumer.

Hey Becket, Thanks for the KIP. As I understand, the intention is to preserve the current behavior with a timestamp of -1 indicating latest timestamp and -2 indicating earliest timestamp. So users can query these offsets using the offsetsForTimes API if they know the magic values. I'm wondering if

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1 and thanks for the excellent write-up! On Wed, Sep 7, 2016 at 10:41 AM, Neha Narkhede wrote: > +1 (binding) > > On Wed, Sep 7, 2016 at 9:49 AM Grant Henke wrote: > > > +1 (non-binding) > > > > On Wed, Sep 7, 2016 at 6:55 AM, Rajini Sivaram < > > rajinisiva...@googlemail.com > > > wrote: > >

[jira] [Created] (KAFKA-4140) Update system tests to allow running tests in parallel

Geoff Anderson created KAFKA-4140: - Summary: Update system tests to allow running tests in parallel Key: KAFKA-4140 URL: https://issues.apache.org/jira/browse/KAFKA-4140 Project: Kafka Issue

[GitHub] kafka pull request #1834: [WIP] KAFKA-4140: make system tests parallel frien...

GitHub user granders opened a pull request: https://github.com/apache/kafka/pull/1834 [WIP] KAFKA-4140: make system tests parallel friendly Updates to take advantage of soon-to-be-released ducktape features. You can merge this pull request into a Git repository by running: $ gi

[jira] [Commented] (KAFKA-4140) Update system tests to allow running tests in parallel

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

Re: [DISCUSS] KIP-79 - ListOffsetRequest v1 and offsetForTime() method in new consumer.

Hi Jason, Thanks for the feedback. That is a good point. For the -1 and -2 semantics, I was just thinking we will preserve the semantics in the wire protocol. For the user facing API, I agree that is not intuitive. We can do one of the following: 1. Add two separate methods: earliestOffsets() and

[jira] [Commented] (KAFKA-4074) Deleting a topic can make it unavailable even if delete.topic.enable is false

[ https://issues.apache.org/jira/browse/KAFKA-4074?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15471686#comment-15471686 ] Joel Koshy commented on KAFKA-4074: --- Yes - totally missed KAFKA-3175 > Deleting a topic

Re: [DISCUSS] KIP-79 - ListOffsetRequest v1 and offsetForTime() method in new consumer.

Hey Becket, I don't have a super strong preference, but I think this earliestOffset(singleton(partition)); captures the intent more clearly than this: offsetsForTimes(singletonMap(partition, -1)); I can understand the desire to keep the API footprint small, but I think the use case is common e

[jira] [Updated] (KAFKA-4141) 2x increase in cpu usage on new Producer API

[ https://issues.apache.org/jira/browse/KAFKA-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Jorgensen updated KAFKA-4141: Summary: 2x increase in cpu usage on new Producer API (was: 2x increase in cp usage on new

[jira] [Created] (KAFKA-4141) 2x increase in cp usage on new Producer API

Andrew Jorgensen created KAFKA-4141: --- Summary: 2x increase in cp usage on new Producer API Key: KAFKA-4141 URL: https://issues.apache.org/jira/browse/KAFKA-4141 Project: Kafka Issue Type: B

[jira] [Updated] (KAFKA-4141) 2x increase in cpu usage on new Producer API

[ https://issues.apache.org/jira/browse/KAFKA-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Jorgensen updated KAFKA-4141: Description: We are seeing about a 2x increase in CPU usage for the new kafka producer comp

[jira] [Updated] (KAFKA-4141) 2x increase in cpu usage on new Producer API

[ https://issues.apache.org/jira/browse/KAFKA-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Jorgensen updated KAFKA-4141: Description: We are seeing about a 2x increase in CPU usage for the new kafka producer comp

[jira] [Updated] (KAFKA-4141) 2x increase in cpu usage on new Producer API

[ https://issues.apache.org/jira/browse/KAFKA-4141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Jorgensen updated KAFKA-4141: Description: We are seeing about a 2x increase in CPU usage for the new kafka producer comp

Re: [DISCUSS] KIP-79 - ListOffsetRequest v1 and offsetForTime() method in new consumer.

That sounds reasonable to me. I'll update the KIP wiki page. On Wed, Sep 7, 2016 at 1:34 PM, Jason Gustafson wrote: > Hey Becket, > > I don't have a super strong preference, but I think this > > earliestOffset(singleton(partition)); > > captures the intent more clearly than this: > > offsetsForT

[jira] [Assigned] (KAFKA-3184) Add Checkpoint for In-memory State Store

[ https://issues.apache.org/jira/browse/KAFKA-3184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jeyhun Karimov reassigned KAFKA-3184: - Assignee: Jeyhun Karimov > Add Checkpoint for In-memory State Store > ---

[GitHub] kafka pull request #1823: Fixes javadoc of Windows, fixes typo in parameter ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1823 --- 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] [Created] (KAFKA-4142) Log files in /data dir date modified keeps being updated?

Clint Hillerman created KAFKA-4142: -- Summary: Log files in /data dir date modified keeps being updated? Key: KAFKA-4142 URL: https://issues.apache.org/jira/browse/KAFKA-4142 Project: Kafka I

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

See Changes: [wangguoz] MINOR: Fixes javadoc of Windows, fixes typo in parameter name of -- [...truncated 3416 lines...] kafka.network.SocketServerTest > tooBigRequestIsRejected STARTED kafka.

[jira] [Commented] (KAFKA-4118) StreamsSmokeTest.test_streams started failing since 18 August build

[ https://issues.apache.org/jira/browse/KAFKA-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472260#comment-15472260 ] Guozhang Wang commented on KAFKA-4118: -- [~enothereska] Could you take a look at this

[jira] [Updated] (KAFKA-4118) StreamsSmokeTest.test_streams started failing since 18 August build

[ https://issues.apache.org/jira/browse/KAFKA-4118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4118: - Assignee: Eno Thereska (was: Guozhang Wang) > StreamsSmokeTest.test_streams started failing since

[GitHub] kafka pull request #1832: MINOR: Document that Connect topics should use com...

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

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

See Changes: [wangguoz] MINOR: Fixes javadoc of Windows, fixes typo in parameter name of -- [...truncated 6875 lines...] kafka.integration.SaslPlaintextTopicMetadataTest > testAutoCreateTopic ST

[jira] [Commented] (KAFKA-4043) User-defined handler for topology restart

[ https://issues.apache.org/jira/browse/KAFKA-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472271#comment-15472271 ] Greg Fodor commented on KAFKA-4043: --- Ah, that should work for us. Thanks! > User-define

[jira] [Resolved] (KAFKA-4043) User-defined handler for topology restart

[ https://issues.apache.org/jira/browse/KAFKA-4043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Greg Fodor resolved KAFKA-4043. --- Resolution: Not A Problem > User-defined handler for topology restart > --

[jira] [Created] (KAFKA-4143) Transient failure in kafka.server.SaslSslReplicaFetchTest.testReplicaFetcherThread

Guozhang Wang created KAFKA-4143: Summary: Transient failure in kafka.server.SaslSslReplicaFetchTest.testReplicaFetcherThread Key: KAFKA-4143 URL: https://issues.apache.org/jira/browse/KAFKA-4143 Proj

[GitHub] kafka pull request #1824: KAFKA-4123: Queryable State returning null for key...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1824 --- 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-4123) Queryable State returning null for key before all stores in instance have been initialized

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

[jira] [Resolved] (KAFKA-4123) Queryable State returning null for key before all stores in instance have been initialized

[ https://issues.apache.org/jira/browse/KAFKA-4123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-4123. -- Resolution: Fixed Issue resolved by pull request 1824 [https://github.com/apache/kafka/pull/1824

[GitHub] kafka pull request #1792: KAFKA-3595: window stores use compact,delete confi...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/1792 --- 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] [Updated] (KAFKA-3595) Add capability to specify replication compact option for stream store

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

[jira] [Commented] (KAFKA-3595) Add capability to specify replication compact option for stream store

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

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1. On Wed, Sep 7, 2016 at 11:18 AM, Jason Gustafson wrote: > +1 and thanks for the excellent write-up! > > On Wed, Sep 7, 2016 at 10:41 AM, Neha Narkhede wrote: > > > +1 (binding) > > > > On Wed, Sep 7, 2016 at 9:49 AM Grant Henke wrote: > > > > > +1 (non-binding) > > > > > > On Wed, Sep 7, 2

[jira] [Commented] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand

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

[GitHub] kafka pull request #1336: KAFKA-3144: Report members with no assigned partit...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/1336 KAFKA-3144: Report members with no assigned partitions in ConsumerGroupCommand This PR makes a couple of enhancements to the `--describe` option of `ConsumerGroupCommand`: 1. Listing m

[GitHub] kafka pull request #1336: KAFKA-3144: Report members with no assigned partit...

Github user vahidhashemian closed the pull request at: https://github.com/apache/kafka/pull/1336 --- 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-3144) report members with no assigned partitions in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472341#comment-15472341 ] ASF GitHub Bot commented on KAFKA-3144: --- GitHub user vahidhashemian reopened a pull

[jira] [Commented] (KAFKA-1006) Consumer loses messages of a new topic with auto.offset.reset = largest

[ https://issues.apache.org/jira/browse/KAFKA-1006?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472427#comment-15472427 ] Patrick Te Tau commented on KAFKA-1006: --- Hi [~guozhang], we are also having trouble

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

See Changes: [jason] MINOR: Document that Connect topics should use compaction -- [...truncated 6845 lines...] kafka.integration.SslTopicMetadataTest > testAliveBrokerListWithNoTopics STARTED

[jira] [Work started] (KAFKA-4131) Multiple Regex KStream-Consumers cause Null pointer exception in addRawRecords in RecordQueue class

[ https://issues.apache.org/jira/browse/KAFKA-4131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4131 started by Bill Bejeck. -- > Multiple Regex KStream-Consumers cause Null pointer exception in > addRawRecords i

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

See Changes: [jason] MINOR: Document that Connect topics should use compaction [wangguoz] KAFKA-4123: Queryable State returning null for key before all stores in [wangguoz] KAFKA-3595: window stores use compact,delete config for chan

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

See Changes: [wangguoz] KAFKA-4123: Queryable State returning null for key before all stores in [wangguoz] KAFKA-3595: window stores use compact,delete config for changelogs -- [...truncated 1

[jira] [Commented] (KAFKA-4033) KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change

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

[GitHub] kafka pull request #1726: KAFKA-4033: KIP-70: Revise Partition Assignment Se...

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

[GitHub] kafka pull request #1726: KAFKA-4033: KIP-70: Revise Partition Assignment Se...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/1726 KAFKA-4033: KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change This PR changes topic subscription semantics so a change in subscription does not immediatel

[jira] [Commented] (KAFKA-4033) KIP-70: Revise Partition Assignment Semantics on New Consumer's Subscription Change

[ https://issues.apache.org/jira/browse/KAFKA-4033?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472599#comment-15472599 ] ASF GitHub Bot commented on KAFKA-4033: --- GitHub user vahidhashemian reopened a pull

Re: [VOTE] KIP-78 Cluster Id (second attempt)

+1 (binding) On Tue, Sep 6, 2016 at 7:46 PM, Ismael Juma wrote: > Hi all, > > I would like to (re)initiate[1] the voting process for KIP-78 Cluster Id: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-78%3A+Cluster+Id > > As explained in the KIP and discussion thread, we see this as a g

[GitHub] kafka pull request #1336: KAFKA-3144: Report members with no assigned partit...

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

[GitHub] kafka pull request #1336: KAFKA-3144: Report members with no assigned partit...

GitHub user vahidhashemian reopened a pull request: https://github.com/apache/kafka/pull/1336 KAFKA-3144: Report members with no assigned partitions in ConsumerGroupCommand This PR makes a couple of enhancements to the `--describe` option of `ConsumerGroupCommand`: 1. Listing m

[jira] [Commented] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand

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

[jira] [Commented] (KAFKA-3144) report members with no assigned partitions in ConsumerGroupCommand

[ https://issues.apache.org/jira/browse/KAFKA-3144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15472806#comment-15472806 ] ASF GitHub Bot commented on KAFKA-3144: --- GitHub user vahidhashemian reopened a pull