[GitHub] kafka pull request #2882: KAFKA-5008: Provide OSGi metadata for Kafka-Client...

GitHub user lostiniceland opened a pull request: https://github.com/apache/kafka/pull/2882 KAFKA-5008: Provide OSGi metadata for Kafka-Clients This change uses the bnd-gradle-plugin for the kafka-clients module in order to generate OSGi metadata. The bnd.bnd file is used by the

[jira] [Commented] (KAFKA-5008) Kafka-Clients not OSGi ready

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

[jira] [Commented] (KAFKA-5065) AbstractCoordinator.ensureCoordinatorReady() stuck in loop if absent any bootstrap servers

[ https://issues.apache.org/jira/browse/KAFKA-5065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978228#comment-15978228 ] james chien commented on KAFKA-5065: I am a newbie, I want to take this issue. > Abst

[GitHub] kafka pull request #2883: 0.10.0 kafka how to delete a deprecated group

GitHub user linjikai opened a pull request: https://github.com/apache/kafka/pull/2883 0.10.0 kafka how to delete a deprecated group I have a group called HBASE1,but I can't find it by kafka-consumer-groups.sh shell。 I do it by call: `/usr/hdp/2.5.0.0-1245/kafka/bin/k

Re: [VOTE] KIP 130: Expose states of active tasks to KafkaStreams public API

+1 (non-binding) Thanks Eno > On 21 Apr 2017, at 05:58, Guozhang Wang wrote: > > +1. Thanks a lot for the KIP! > > Guozhang > > On Wed, Apr 5, 2017 at 1:57 PM, Florian Hussonnois > wrote: > >> Hi All, >> >> I would like to start the vote for the KIP-130 : >> >> https://cwiki.apache.org/co

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Hi Guozhang, Thanks for the feedback. Comments inline: > 1. Regarding the user-facing semantics, I thought we will claim that > "KTables generated from functions that do NOT specify a table name will NOT > be queryable"; but it seems you're proposing to claim it "may not possible > to be queryabl

[GitHub] kafka pull request #2884: MINOR: fix javadoc comment

GitHub user mihbor opened a pull request: https://github.com/apache/kafka/pull/2884 MINOR: fix javadoc comment Here's where it's called: https://github.com/apache/kafka/blob/trunk/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamTransform.java#L64-L67 You

[jira] [Commented] (KAFKA-4935) Consider disabling record level CRC checks for message format V2

[ https://issues.apache.org/jira/browse/KAFKA-4935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978384#comment-15978384 ] Ismael Juma commented on KAFKA-4935: While doing this, we should also consider if we s

[GitHub] kafka pull request #2879: KAFKA-5094: Replace SCRAM credentials in broker lo...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2879 --- 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-5094) Censor SCRAM config change logging

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

[jira] [Resolved] (KAFKA-5094) Censor SCRAM config change logging

[ https://issues.apache.org/jira/browse/KAFKA-5094?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-5094. Resolution: Fixed Fix Version/s: 0.11.0.0 > Censor SCRAM config change logging >

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

See Changes: [ismael] KAFKA-5094; Replace SCRAM credentials in broker logs with tag hidden -- Started by an SCM change [EnvInject] - Loading node environment variables. Bu

Re: [VOTE] 0.10.2.1 RC2

Please consider including https://issues.apache.org/jira/browse/KAFKA-4814 in the new RC. Kind regards, Stevo Slavic. On Fri, Apr 21, 2017 at 12:43 AM, Gwen Shapira wrote: > This is what happens when you do a last-minute merge :( > > Will roll a new RC tomorrow morning. Please find all the bugs

[GitHub] kafka pull request #2842: MINOR: findbugs should generate XML reports

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

[GitHub] kafka pull request #2885: MINOR: Logger parameter corrected.

GitHub user Kamal15 opened a pull request: https://github.com/apache/kafka/pull/2885 MINOR: Logger parameter corrected. - typo error corrected (spelling) You can merge this pull request into a Git repository by running: $ git pull https://github.com/Kamal15/kafka log Alternati

[jira] [Created] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

Ismael Juma created KAFKA-5100: -- Summary: ProducerPerformanceService failing due to parsing error Key: KAFKA-5100 URL: https://issues.apache.org/jira/browse/KAFKA-5100 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-5101) Remove KafkaController's incrementControllerEpoch method parameter

Balint Molnar created KAFKA-5101: Summary: Remove KafkaController's incrementControllerEpoch method parameter Key: KAFKA-5101 URL: https://issues.apache.org/jira/browse/KAFKA-5101 Project: Kafka

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978654#comment-15978654 ] Domenico Di Giulio commented on KAFKA-5016: --- [~vahid] Me too: I can only reprod

[jira] [Work started] (KAFKA-5101) Remove KafkaController's incrementControllerEpoch method parameter

[ https://issues.apache.org/jira/browse/KAFKA-5101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5101 started by Balint Molnar. > Remove KafkaController's incrementControllerEpoch method parameter > -

[GitHub] kafka pull request #2886: KAFKA-5101 Remove KafkaController's incrementContr...

GitHub user baluchicken opened a pull request: https://github.com/apache/kafka/pull/2886 KAFKA-5101 Remove KafkaController's incrementControllerEpoch method p… @ijuma minor fix. can you please review. You can merge this pull request into a Git repository by running: $ git pul

[jira] [Commented] (KAFKA-5101) Remove KafkaController's incrementControllerEpoch method parameter

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

[jira] [Created] (KAFKA-5102) Refactor AdminUtils to use zkUtils methods instead of zkUtils.zkClient

Balint Molnar created KAFKA-5102: Summary: Refactor AdminUtils to use zkUtils methods instead of zkUtils.zkClient Key: KAFKA-5102 URL: https://issues.apache.org/jira/browse/KAFKA-5102 Project: Kafka

[jira] [Work started] (KAFKA-5102) Refactor AdminUtils to use zkUtils methods instead of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5102 started by Balint Molnar. > Refactor AdminUtils to use zkUtils methods instead of zkUtils.zkClient > --

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

See

[GitHub] kafka pull request #2885: MINOR: Logger parameter corrected.

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2885 --- 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-5102) Refactor core components to use zkUtils methods instead of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5102: - Summary: Refactor core components to use zkUtils methods instead of zkUtils.zkClient (was: Refact

[jira] [Updated] (KAFKA-5102) Refactor core components to use zkUtils methods instead of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balint Molnar updated KAFKA-5102: - Component/s: (was: admin) core > Refactor core components to use zkUtils meth

[jira] [Created] (KAFKA-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

Balint Molnar created KAFKA-5103: Summary: Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient Key: KAFKA-5103 URL: https://issues.apache.org/jira/browse/KAFKA-5103 Project: Kafka

[jira] [Work started] (KAFKA-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5103 started by Balint Molnar. > Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient > ---

[jira] [Work stopped] (KAFKA-5102) Refactor core components to use zkUtils methods instead of zkUtils.zkClient

[ https://issues.apache.org/jira/browse/KAFKA-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-5102 stopped by Balint Molnar. > Refactor core components to use zkUtils methods instead of zkUtils.zkClient > -

[jira] [Commented] (KAFKA-5097) KafkaConsumer.poll throws IllegalStateException

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

[GitHub] kafka pull request #2887: KAFKA-5097: Add testFetchAfterPartitionWithFetched...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/2887 KAFKA-5097: Add testFetchAfterPartitionWithFetchedRecordsIsUnassigned You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-5097-unit-

[GitHub] kafka pull request #2888: KAFKA-5103 Refactor AdminUtils to use zkUtils meth...

GitHub user baluchicken opened a pull request: https://github.com/apache/kafka/pull/2888 KAFKA-5103 Refactor AdminUtils to use zkUtils methods instad of zkUti… @ijuma plz review. You can merge this pull request into a Git repository by running: $ git pull https://github.com/

[jira] [Commented] (KAFKA-5103) Refactor AdminUtils to use zkUtils methods instad of zkUtils.zkClient

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

[GitHub] kafka pull request #2889: KAFKA-4928: Add integration test for DumpLogSegmen...

GitHub user original-brownbear opened a pull request: https://github.com/apache/kafka/pull/2889 KAFKA-4928: Add integration test for DumpLogSegments Adding tests for `kafka.tools.DumpLogSegments` You can merge this pull request into a Git repository by running: $ git pull https

[jira] [Commented] (KAFKA-4928) Add integration test for DumpLogSegments

[ https://issues.apache.org/jira/browse/KAFKA-4928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978846#comment-15978846 ] ASF GitHub Bot commented on KAFKA-4928: --- GitHub user original-brownbear opened a pul

[jira] [Commented] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

[ https://issues.apache.org/jira/browse/KAFKA-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15978863#comment-15978863 ] Jun Rao commented on KAFKA-5100: It seems the issue is that we now print the total before

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

See Changes: [ismael] MINOR: Fix logging in ControlRecordType -- [...truncated 1.55 MB...] kafka.log.LogTest > testReopenThenTruncate PASSED kafka.log.LogTest > testOldPr

Re: [DISCUSS] KIP-138: Change punctuate semantics

Thanks Michal, I agree Transformer.punctuate should also be void, but we can deprecate that too in favor of the new interface. Thanks for the javadoc PR! Cheers, Damian On Fri, 21 Apr 2017 at 09:31 Michal Borowiecki < michal.borowie...@openbet.com> wrote: > Yes, that looks better to me. > > Not

Re: [VOTE] KIP 130: Expose states of active tasks to KafkaStreams public API

+1 On Fri, 21 Apr 2017 at 09:06 Eno Thereska wrote: > +1 (non-binding) > > Thanks > Eno > > > On 21 Apr 2017, at 05:58, Guozhang Wang wrote: > > > > +1. Thanks a lot for the KIP! > > > > Guozhang > > > > On Wed, Apr 5, 2017 at 1:57 PM, Florian Hussonnois < > fhussonn...@gmail.com> > > wrote: >

[jira] [Created] (KAFKA-5104) DumpLogSegments should not open index files with `rw`

Yeva Byzek created KAFKA-5104: - Summary: DumpLogSegments should not open index files with `rw` Key: KAFKA-5104 URL: https://issues.apache.org/jira/browse/KAFKA-5104 Project: Kafka Issue Type: Imp

[GitHub] kafka pull request #2890: KAFKA-5100: ProducerPerformanceService failing due...

GitHub user junrao opened a pull request: https://github.com/apache/kafka/pull/2890 KAFKA-5100: ProducerPerformanceService failing due to parsing error You can merge this pull request into a Git repository by running: $ git pull https://github.com/junrao/kafka kafka-5100 Alte

[jira] [Commented] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

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

[jira] [Updated] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-4755: Fix Version/s: (was: 0.10.2.1) > SimpleBenchmark test fails for streams > --

Re: [VOTE] 0.10.2.1 RC2

Stevo, This is a sensible fix to backport, but since it isn't a regression and since we are on our fourth RC, I want to be super conservative here and not add anything that isn't absolutely critical. Gwen On Fri, Apr 21, 2017 at 3:05 AM, Stevo Slavić wrote: > Please consider including https://

[jira] [Commented] (KAFKA-4755) SimpleBenchmark test fails for streams

[ https://issues.apache.org/jira/browse/KAFKA-4755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979000#comment-15979000 ] Gwen Shapira commented on KAFKA-4755: - removed 0.10.2.1 from fixVersion since it isn't

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979030#comment-15979030 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] Thanks for confirming. I'll

[VOTE] 0.10.2.1 RC3

Hello Kafka users, developers, friends, romans, countrypersons, This is the fourth (!) candidate for release of Apache Kafka 0.10.2.1. It is a bug fix release, so we have lots of bug fixes, some super important. Release notes for the 0.10.2.1 release: http://home.apache.org/~gwenshap/kafka-0.10.

[jira] [Created] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

Dmitry Minkovsky created KAFKA-5105: --- Summary: ReadOnlyKeyValueStore range scans are not ordered Key: KAFKA-5105 URL: https://issues.apache.org/jira/browse/KAFKA-5105 Project: Kafka Issue T

[jira] [Updated] (KAFKA-5105) ReadOnlyKeyValueStore range scans are not ordered

[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dmitry Minkovsky updated KAFKA-5105: Description: Following up with this thread https://www.mail-archive.com/users@kafka.apache.

[GitHub] kafka pull request #2881: MINOR: Remove redundant CRC validation for non-com...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2881 --- 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-5105) ReadOnlyKeyValueStore range scans are not ordered

[ https://issues.apache.org/jira/browse/KAFKA-5105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-5105: --- Issue Type: Improvement (was: Bug) > ReadOnlyKeyValueStore range scans are not ordered >

[VOTE] KIP-114: KTable state stores and improved semantics

Hi there, Unless there are more issues on the discuss thread, I'd like to start the vote on KIP-114. https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3A+KTable+state+stores+and+improved+semantics

[jira] [Created] (KAFKA-5106) Improve test coverage for broker CRC validation

Jason Gustafson created KAFKA-5106: -- Summary: Improve test coverage for broker CRC validation Key: KAFKA-5106 URL: https://issues.apache.org/jira/browse/KAFKA-5106 Project: Kafka Issue Type:

[jira] [Updated] (KAFKA-5106) Improve test coverage for broker CRC validation

[ https://issues.apache.org/jira/browse/KAFKA-5106?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-5106: --- Description: Test cases should ensure that CRC errors are detected across all message formats

[GitHub] kafka pull request #2868: Minor fix record collector

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

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

I agree with Eno about the renaming. @Eno: can you add this to the Wiki Discussion page? -Matthias On 4/21/17 1:11 AM, Eno Thereska wrote: > Hi Guozhang, > > Thanks for the feedback. Comments inline: > >> 1. Regarding the user-facing semantics, I thought we will claim that >> "KTables genera

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 On 4/21/17 10:39 AM, Eno Thereska wrote: > Hi there, > > Unless there are more issues on the discuss thread, I'd like to start the > vote on KIP-114. > https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3A+KTable+state+stores+and+improved+semantics > >

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 On Fri, Apr 21, 2017 at 1:48 PM Matthias J. Sax wrote: > +1 > > On 4/21/17 10:39 AM, Eno Thereska wrote: > > Hi there, > > > > Unless there are more issues on the discuss thread, I'd like to start > the vote on KIP-114. > https://cwiki.apache.org/confluence/display/KAFKA/KIP-114%3A+KTable+stat

[jira] [Updated] (KAFKA-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

[ https://issues.apache.org/jira/browse/KAFKA-4564?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4564: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[GitHub] kafka pull request #2837: KAFKA-4564: Add system test for pre-0.10 brokers

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2837 --- 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-4564) When the destination brokers are down or misconfigured in config, Streams should fail fast

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

[jira] [Created] (KAFKA-5107) investigate removing preferred replica leader election state from ControllerContext

Onur Karaman created KAFKA-5107: --- Summary: investigate removing preferred replica leader election state from ControllerContext Key: KAFKA-5107 URL: https://issues.apache.org/jira/browse/KAFKA-5107 Proje

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Sounds good. Thanks. On Fri, Apr 21, 2017 at 10:48 AM, Matthias J. Sax wrote: > I agree with Eno about the renaming. > > @Eno: can you add this to the Wiki Discussion page? > > > -Matthias > > > On 4/21/17 1:11 AM, Eno Thereska wrote: > > Hi Guozhang, > > > > Thanks for the feedback. Comments in

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 On Fri, Apr 21, 2017 at 10:52 AM, Bill Bejeck wrote: > +1 > On Fri, Apr 21, 2017 at 1:48 PM Matthias J. Sax > wrote: > > > +1 > > > > On 4/21/17 10:39 AM, Eno Thereska wrote: > > > Hi there, > > > > > > Unless there are more issues on the discuss thread, I'd like to start > > the vote on KIP

Re: [DISCUSS] KIP 141 - ProducerRecordBuilder Interface

Ismael's comment is quite reasonable. And I actually like the idea about `withForcedPartition` -- it helps newcomers to understand the API better. Even if I don't agree with some of you reasoning: > I was always told that the key is solely the determining factor Bad teacher? > I find it incredi

Re: [VOTE] KIP-114: KTable state stores and improved semantics

+1 On Fri, Apr 21, 2017 at 11:06 AM, Guozhang Wang wrote: > +1 > > On Fri, Apr 21, 2017 at 10:52 AM, Bill Bejeck wrote: > > > +1 > > On Fri, Apr 21, 2017 at 1:48 PM Matthias J. Sax > > wrote: > > > > > +1 > > > > > > On 4/21/17 10:39 AM, Eno Thereska wrote: > > > > Hi there, > > > > > > > > Un

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

See Changes: [jason] MINOR: Remove redundant CRC validation for non-compressed records in -- [...truncated 788.24 KB...] kafka.log.LogTest > testReopenThenTruncate PASSED

[jira] [Created] (KAFKA-5108) Add support for reading PID snapshot files to DumpLogSegments

Jason Gustafson created KAFKA-5108: -- Summary: Add support for reading PID snapshot files to DumpLogSegments Key: KAFKA-5108 URL: https://issues.apache.org/jira/browse/KAFKA-5108 Project: Kafka

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

See Changes: [jason] MINOR: Remove redundant CRC validation for non-compressed records in -- [...truncated 790.94 KB...] kafka.integration.SaslPlaintextTopicMetadataTest >

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

It would not give the same information as the new API. Thus, it would be inconsistent (and this would be really bad IMHO.) I would really like to remove (ie, deprecate) it. It was a "hot fix" to give some runtime information to the user. But with this KIP, we get a proper first class API and thus

Re: [DISCUSS] KIP-114: KTable materialization and improved semantics

Added the .tostream() discussion in the Wiki. Thanks Eno > On 21 Apr 2017, at 18:48, Matthias J. Sax wrote: > > I agree with Eno about the renaming. > > @Eno: can you add this to the Wiki Discussion page? > > > -Matthias > > > On 4/21/17 1:11 AM, Eno Thereska wrote: >> Hi Guozhang, >> >> T

Re: Kafka-Streams: Cogroup

Hi Kyle, Sorry for the delay in replying. I think it's worth doing a KIP for this one. One super helpful thing with KIPs is to list a few more scenarios that would benefit from this approach. In particular it seems the main benefit is from reducing the number of state stores. Does this necessarily

[GitHub] kafka pull request #2890: KAFKA-5100: ProducerPerformanceService failing due...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2890 --- 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] [Resolved] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

[ https://issues.apache.org/jira/browse/KAFKA-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-5100. Resolution: Fixed Issue resolved by pull request 2890 [https://github.com/apache/kafka/pull/2890] > Produce

[jira] [Commented] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

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

[jira] [Created] (KAFKA-5109) validate the output of ProducerPerformance and ConsumerPerformance in integration test

Jun Rao created KAFKA-5109: -- Summary: validate the output of ProducerPerformance and ConsumerPerformance in integration test Key: KAFKA-5109 URL: https://issues.apache.org/jira/browse/KAFKA-5109 Project: Kaf

[GitHub] kafka pull request #2891: kafka 3355

GitHub user garmes-gdev opened a pull request: https://github.com/apache/kafka/pull/2891 kafka 3355 You can merge this pull request into a Git repository by running: $ git pull https://github.com/garmes-gdev/kafka trunk Alternatively you can review and apply these changes as

[jira] [Commented] (KAFKA-5100) ProducerPerformanceService failing due to parsing error

[ https://issues.apache.org/jira/browse/KAFKA-5100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979291#comment-15979291 ] Jun Rao commented on KAFKA-5100: Filed https://issues.apache.org/jira/browse/KAFKA-5109 so

[jira] [Updated] (KAFKA-5109) validate the output of ProducerPerformance and ConsumerPerformance in integration test

[ https://issues.apache.org/jira/browse/KAFKA-5109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-5109: --- Description: Our system tests parse the output of ProducerPerformance and ConsumerPerformance. So, it would b

[GitHub] kafka pull request #2788: MINOR: improve test cleanup

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

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

I'd agree with Matthias. @Eno do you have any specific use case in mind to better keep the `toString` function? Guozhang On Fri, Apr 21, 2017 at 11:41 AM, Matthias J. Sax wrote: > It would not give the same information as the new API. Thus, it would be > inconsistent (and this would be reall

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

See

[jira] [Updated] (KAFKA-5090) Kafka Streams SessionStore.findSessions javadoc broken

[ https://issues.apache.org/jira/browse/KAFKA-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-5090: - Resolution: Fixed Fix Version/s: 0.11.0.0 Status: Resolved (was: Patch Available

[GitHub] kafka pull request #2874: KAFKA-5090 Kafka Streams SessionStore.findSessions...

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

[DISCUSS] KIP-140: Add administrative RPCs for adding, deleting, and listing ACLs

Hi all, As part of the AdminClient work, we would like to add methods for adding, deleting, and listing access control lists (ACLs). I wrote up a KIP to discuss implementing requests for those operations, as well as AdminClient APIs. Take a look at: https://cwiki.apache.org/confluence/display/KA

[jira] [Commented] (KAFKA-5090) Kafka Streams SessionStore.findSessions javadoc broken

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

[GitHub] kafka pull request #2884: MINOR: fix javadoc comment

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2884 --- 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-5110) ConsumerGroupCommand error handling improvement

Dustin Cote created KAFKA-5110: -- Summary: ConsumerGroupCommand error handling improvement Key: KAFKA-5110 URL: https://issues.apache.org/jira/browse/KAFKA-5110 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP 130: Expose states of active tasks to KafkaStreams public API

Ok, I’m convinced. Let’s depreciate. Thanks Eno > On Apr 21, 2017, at 9:20 PM, Guozhang Wang wrote: > > I'd agree with Matthias. > > @Eno do you have any specific use case in mind to better keep the `toString` > function? > > > Guozhang > > > On Fri, Apr 21, 2017 at 11:41 AM, Matthias J. S

[jira] [Commented] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979433#comment-15979433 ] Nikki Thean commented on KAFKA-5055: [~guozhang] Sure. Streams config properties were

[jira] [Comment Edited] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979433#comment-15979433 ] Nikki Thean edited comment on KAFKA-5055 at 4/21/17 9:38 PM: -

[jira] [Comment Edited] (KAFKA-5055) Kafka Streams skipped-records-rate sensor producing nonzero values even when FailOnInvalidTimestamp is used as extractor

[ https://issues.apache.org/jira/browse/KAFKA-5055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979433#comment-15979433 ] Nikki Thean edited comment on KAFKA-5055 at 4/21/17 9:38 PM: -

[jira] [Commented] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979482#comment-15979482 ] Vahid Hashemian commented on KAFKA-5016: [~domenico74] I think you are seeing the

[jira] [Updated] (KAFKA-5016) Consumer hang in poll method while rebalancing is in progress

[ https://issues.apache.org/jira/browse/KAFKA-5016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Domenico Di Giulio updated KAFKA-5016: -- I am currently out of the office, with limited access to my e-mail. I will be back at work o

[jira] [Updated] (KAFKA-5107) remove preferred replica election state from ControllerContext

[ https://issues.apache.org/jira/browse/KAFKA-5107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Onur Karaman updated KAFKA-5107: Summary: remove preferred replica election state from ControllerContext (was: investigate removing

[jira] [Commented] (KAFKA-5110) ConsumerGroupCommand error handling improvement

[ https://issues.apache.org/jira/browse/KAFKA-5110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979502#comment-15979502 ] Vahid Hashemian commented on KAFKA-5110: [~cotedm] Could you please share the step

[jira] [Commented] (KAFKA-617) Refactor KafkaApis.handleOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979524#comment-15979524 ] Guozhang Wang commented on KAFKA-617: - [~jozi-k] I think it has been named to {{handleL

[jira] [Commented] (KAFKA-454) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15979525#comment-15979525 ] Guozhang Wang commented on KAFKA-454: - Thanks for pointing out. > ProducerSendThread c

[jira] [Updated] (KAFKA-617) Refactor KafkaApis.handleListOffsetRequest

[ https://issues.apache.org/jira/browse/KAFKA-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-617: Summary: Refactor KafkaApis.handleListOffsetRequest (was: Refactor KafkaApis.handleOffsetRequest) >

  1   2   >