[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Component/s: unit tests > Transient test failures for >

[jira] [Reopened] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-1482: -- > Transient test failures for >

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Fix Version/s: (was: 0.8.2.0) 0.10.3.0 > Transient test failures for >

[jira] [Commented] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820321#comment-15820321 ] Guozhang Wang commented on KAFKA-1482: -- Saw this test failure in another example:

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest.testPartitionReassignmentDuringDeleteTopic

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Summary: Transient test failures for

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-1482: - Description: {code} Stacktrace kafka.common.TopicAlreadyMarkedForDeletionException: topic test

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

See Changes: [wangguoz] KAFKA-4114: Allow different offset reset strategies [wangguoz] KAFKA-3452; Follow-up: Add SessionWindows -- [...truncated 18378 lines...]

[jira] [Resolved] (KAFKA-2543) facing test failure while building apache-kafka from source

[ https://issues.apache.org/jira/browse/KAFKA-2543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2543. -- Resolution: Cannot Reproduce > facing test failure while building apache-kafka from source >

Re: [VOTE] KIP-107 Add purgeDataBefore() API in AdminClient

LGTM, +1 On Wed, Jan 11, 2017 at 1:01 PM, Dong Lin wrote: > Hi all, > > It seems that there is no further concern with the KIP-107. At this point > we would like to start the voting process. The KIP can be found at > https://cwiki.apache.org/confluence/display/KAFKA/KIP-107

[jira] [Commented] (KAFKA-4616) Message log is seen when kafka-producer-perf-test.sh is running and any broker restarted in middle in-between

[ https://issues.apache.org/jira/browse/KAFKA-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820267#comment-15820267 ] huxi commented on KAFKA-4616: - Appending acks option to the command as this: --producer-props

[jira] [Commented] (KAFKA-4616) Message log is seen when kafka-producer-perf-test.sh is running and any broker restarted in middle in-between

[ https://issues.apache.org/jira/browse/KAFKA-4616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820237#comment-15820237 ] sandeep kumar singh commented on KAFKA-4616: is there any way to add this to perf-test

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

See Changes: [ismael] KAFKA-4180; Support clients with different authentication credentials in -- [...truncated 34351 lines...] org.apache.kafka.streams.KafkaStreamsTest > testCleanup PASSED

[jira] [Commented] (KAFKA-4604) Gradle Eclipse plugin creates projects for non project subfolders

[ https://issues.apache.org/jira/browse/KAFKA-4604?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15820176#comment-15820176 ] Guozhang Wang commented on KAFKA-4604: -- PR link：https://github.com/apache/kafka/pull/2324 > Gradle

[jira] [Commented] (KAFKA-3452) Support session windows

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

[GitHub] kafka pull request #2342: KAFKA-3452: follow-up -- introduce SesssionWindows

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2342 --- 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-4114) Allow for different "auto.offset.reset" strategies for different input streams

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

[GitHub] kafka pull request #2007: KAFKA-4114: allow different offset reset strategie...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2007 --- 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] [Updated] (KAFKA-4114) Allow for different "auto.offset.reset" strategies for different input streams

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

Re: [ANNOUNCE] New committer: Grant Henke

Grant, Thanks for all your contribution! Congratulations! Jun On Wed, Jan 11, 2017 at 2:51 PM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88

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

See

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

Okay, I will have a try. Thanks Ewen for the guidance!! Best, Dongjin On Thu, Jan 12, 2017 at 6:44 AM, Ismael Juma wrote: > That's a good point Ewen. Dongjin, you could use the branch that Ewen > linked for the performance testing. It would also help validate the PR. > >

[jira] [Created] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

Jason Gustafson created KAFKA-4622: -- Summary: KafkaConsumer does not properly handle authorization errors from offset fetches Key: KAFKA-4622 URL: https://issues.apache.org/jira/browse/KAFKA-4622

[jira] [Updated] (KAFKA-4622) KafkaConsumer does not properly handle authorization errors from offset fetches

[ https://issues.apache.org/jira/browse/KAFKA-4622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-4622: --- Fix Version/s: 0.10.2.0 > KafkaConsumer does not properly handle authorization errors from

[jira] [Commented] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

[ https://issues.apache.org/jira/browse/KAFKA-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819890#comment-15819890 ] ASF GitHub Bot commented on KAFKA-2944: --- Github user jinxing64 closed the pull request at:

[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=15819893#comment-15819893 ] ASF GitHub Bot commented on KAFKA-2875: --- Github user jinxing64 closed the pull request at:

[GitHub] kafka pull request #693: KAFKA-2875: remove slf4j multi binding warnings whe...

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

[GitHub] kafka pull request #723: KAFKA-2944: fix NullPointerException in KafkaConfig...

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

[GitHub] kafka pull request #783: KAFKA-3106: Fix updating an existing connector conf...

Github user jinxing64 closed the pull request at: https://github.com/apache/kafka/pull/783 --- 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-3106) After PUT a connector config from REST API, GET a connector config will fail

[ https://issues.apache.org/jira/browse/KAFKA-3106?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819889#comment-15819889 ] ASF GitHub Bot commented on KAFKA-3106: --- Github user jinxing64 closed the pull request at:

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

See Changes: [jason] KAFKA-4426; Add close with timeout for KafkaConsumer (KIP-102) -- [...truncated 18310 lines...] org.apache.kafka.streams.KafkaStreamsTest > testNumberDefaultMetrics

[jira] [Commented] (KAFKA-4621) Fetch Request V3 docs list max_bytes twice

[ https://issues.apache.org/jira/browse/KAFKA-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819844#comment-15819844 ] Jeff Widman commented on KAFKA-4621: Yeah, I saw that... perhaps the descriptions could also be

[jira] [Resolved] (KAFKA-4180) Shared authentication with multiple active Kafka producers/consumers

[ https://issues.apache.org/jira/browse/KAFKA-4180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma resolved KAFKA-4180. Resolution: Fixed Fix Version/s: 0.10.2.0 Issue resolved by pull request 2293

[jira] [Commented] (KAFKA-4180) Shared authentication with multiple active Kafka producers/consumers

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

[GitHub] kafka pull request #2293: KAFKA-4180 : Authentication with multiple actives ...

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

[GitHub] kafka pull request #2348: MINOR: Minor improvements in consumer close timeou...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/2348 MINOR: Minor improvements in consumer close timeout handling You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[jira] [Commented] (KAFKA-4621) Fetch Request V3 docs list max_bytes twice

[ https://issues.apache.org/jira/browse/KAFKA-4621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819790#comment-15819790 ] Ismael Juma commented on KAFKA-4621: One of them is for the whole request and the other is for the

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

See -- [...truncated 18225 lines...] org.apache.kafka.streams.KafkaStreamsTest > testStartAndClose PASSED org.apache.kafka.streams.KafkaStreamsTest > testCloseIsIdempotent STARTED

[jira] [Created] (KAFKA-4621) Fetch Request V3 docs list max_bytes twice

Jeff Widman created KAFKA-4621: -- Summary: Fetch Request V3 docs list max_bytes twice Key: KAFKA-4621 URL: https://issues.apache.org/jira/browse/KAFKA-4621 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #2347: Initial commit of partition assignment check in co...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/2347 Initial commit of partition assignment check in console consumer. With this patch, the consumer will considered initialized in the ProduceConsumeValidate tests only if it has partitions assigned.

[jira] [Updated] (KAFKA-4426) Add consumer.close(timeout, unit) for graceful close with timeout

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

[GitHub] kafka pull request #2285: KAFKA-4426: Add close with timeout for KafkaConsum...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2285 --- 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-4426) Add consumer.close(timeout, unit) for graceful close with timeout

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

Re: [VOTE] KIP-109: Old Consumer Deprecation

+1 from me. I'm in favor of deprecating in 0.10.2 if possible, or in the next release at the latest. As Ewen and Stevo have pointed out, it is already effectively deprecated. -Jason On Wed, Jan 11, 2017 at 4:01 PM, Stevo Slavić wrote: > +1 (non-binding) and for deprecating

[jira] [Created] (KAFKA-4620) Connection exceptions in JMXTool do not make it to the top level

Apurva Mehta created KAFKA-4620: --- Summary: Connection exceptions in JMXTool do not make it to the top level Key: KAFKA-4620 URL: https://issues.apache.org/jira/browse/KAFKA-4620 Project: Kafka

[jira] [Commented] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819602#comment-15819602 ] Guozhang Wang commented on KAFKA-3875: -- Another failure with different error message: {code}

Re: [VOTE] KIP-109: Old Consumer Deprecation

+1 (non-binding) and for deprecating it ASAP. It's already actually deprecated, not supported, new features and bug fixes end up only in new clients API, so would be fair to communicate clearly to users in old consumer API that it's deprecated, it's further or new use is discouraged and if one

[jira] [Updated] (KAFKA-4588) QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable is occasionally failing on jenkins

[ https://issues.apache.org/jira/browse/KAFKA-4588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4588: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 >

[jira] [Updated] (KAFKA-4222) Transient failure in QueryableStateIntegrationTest.queryOnRebalance

[ https://issues.apache.org/jira/browse/KAFKA-4222?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-4222: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > Transient failure in

[jira] [Commented] (KAFKA-3875) Transient test failure: kafka.api.SslProducerSendTest.testSendNonCompressedMessageWithCreateTime

[ https://issues.apache.org/jira/browse/KAFKA-3875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819596#comment-15819596 ] Guozhang Wang commented on KAFKA-3875: -- Another failure case of this:

[jira] [Updated] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-3896: - Issue Type: Sub-task (was: Bug) Parent: KAFKA-2054 > Unstable test >

[jira] [Reopened] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang reopened KAFKA-3896: -- > Unstable test > KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations >

[jira] [Commented] (KAFKA-3896) Unstable test KStreamRepartitionJoinTest.shouldCorrectlyRepartitionOnJoinOperations

[ https://issues.apache.org/jira/browse/KAFKA-3896?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819555#comment-15819555 ] Guozhang Wang commented on KAFKA-3896: -- {code} java.lang.AssertionError: Condition not met within

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

See Changes: [ismael] KAFKA-4507; Clients should support older brokers (KIP-97) [wangguoz] KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical -- [...truncated 15590

Re: [VOTE] KIP-109: Old Consumer Deprecation

Ewen, I think a policy of giving it a minimum of one year between deprecation and removal for this case seems reasonable. Ismael On Wed, Jan 11, 2017 at 5:45 AM, Ewen Cheslack-Postava wrote: > Ismael, > > Is that regardless of whether it ends up being a major/minor version?

Re: [VOTE] KIP-108: Create Topic Policy

Thanks to everyone who voted and provided feedback. The vote has passed with 4 binding +1s (Joel, Gwen, Neha, Sriram) and 4 non-binding +1s (Edoardo, Roger, Jon, Apurva). I have updated the relevant wiki pages. Ismael On Tue, Jan 10, 2017 at 1:00 AM, Sriram Subramanian

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 (non-binding) On Wed, Jan 11, 2017 at 11:12 PM, Stevo Slavić wrote: > +1 (non-binding) > > On Thu, Jan 12, 2017 at 12:11 AM, Guozhang Wang > wrote: > > > +1 > > > > On Wed, Jan 11, 2017 at 12:09 PM, Jeff Widman wrote: > > > > > +1

[GitHub] kafka-site pull request #39: New europe meetup links

GitHub user derrickdoo opened a pull request: https://github.com/apache/kafka-site/pull/39 New europe meetup links Added 2 new meetups to the Events page You can merge this pull request into a Git repository by running: $ git pull https://github.com/derrickdoo/kafka-site

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 (non-binding) On Thu, Jan 12, 2017 at 12:11 AM, Guozhang Wang wrote: > +1 > > On Wed, Jan 11, 2017 at 12:09 PM, Jeff Widman wrote: > > > +1 nonbinding. We were bit by this in a production environment. > > > > On Wed, Jan 11, 2017 at 11:42 AM, Ian

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 On Wed, Jan 11, 2017 at 12:09 PM, Jeff Widman wrote: > +1 nonbinding. We were bit by this in a production environment. > > On Wed, Jan 11, 2017 at 11:42 AM, Ian Wrigley wrote: > > > +1 (non-binding) > > > > > On Jan 11, 2017, at 11:33 AM, Jay Kreps

Re: [ANNOUNCE] New committer: Grant Henke

Congrats, Grant!! -James > On Jan 11, 2017, at 11:51 AM, Gwen Shapira wrote: > > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88 patches, 90 code reviews, countless great

Re: [ANNOUNCE] New committer: Grant Henke

Congrats Grant! On Wed, Jan 11, 2017 at 2:17 PM, Kaufman Ng wrote: > Congrats Grant! > > On Wed, Jan 11, 2017 at 4:28 PM, Jay Kreps wrote: > > > Congrats Grant! > > > > -Jay > > > > On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shapira >

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

See Changes: [ismael] KAFKA-4507; Clients should support older brokers (KIP-97) [wangguoz] KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical -- [...truncated 3936 lines...]

[jira] [Updated] (KAFKA-1894) Avoid long or infinite blocking in the consumer

[ https://issues.apache.org/jira/browse/KAFKA-1894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-1894: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Avoid long or infinite blocking in

[jira] [Updated] (KAFKA-4507) The client should send older versions of requests to the broker if necessary

[ https://issues.apache.org/jira/browse/KAFKA-4507?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-4507: --- Resolution: Fixed Status: Resolved (was: Patch Available) > The client should send older

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

That's a good point Ewen. Dongjin, you could use the branch that Ewen linked for the performance testing. It would also help validate the PR. Ismael On Wed, Jan 11, 2017 at 9:38 PM, Ewen Cheslack-Postava wrote: > FYI, there's an outstanding patch for getting some JMH

Re: [DISCUSS] KIP-110: Add Codec for ZStandard Compression

FYI, there's an outstanding patch for getting some JMH benchmarking setup: https://github.com/apache/kafka/pull/1712 I haven't found time to review it (and don't really know JMH well anyway) but it might be worth getting that landed so we can use it for this as well. -Ewen On Wed, Jan 11, 2017

[jira] [Comment Edited] (KAFKA-2610) Metrics for SSL handshake

[ https://issues.apache.org/jira/browse/KAFKA-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819238#comment-15819238 ] Felix A Mercado edited comment on KAFKA-2610 at 1/11/17 9:31 PM: - So, i

[jira] [Commented] (KAFKA-2610) Metrics for SSL handshake

[ https://issues.apache.org/jira/browse/KAFKA-2610?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819238#comment-15819238 ] Felix A Mercado commented on KAFKA-2610: So, i guess I will take a stab at this:

Re: [ANNOUNCE] New committer: Grant Henke

Congrats Grant! -Jay On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88 patches, 90 code reviews, countless great >

[jira] [Updated] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

[ https://issues.apache.org/jira/browse/KAFKA-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4619: --- Status: Patch Available (was: In Progress) > Dissallow to output records with unknown keys

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

See

[jira] [Commented] (KAFKA-4612) Simple Kafka Streams app causes "ClassCastException: java.lang.String cannot be cast to [B"

[ https://issues.apache.org/jira/browse/KAFKA-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819196#comment-15819196 ] Kurt Ostfeld commented on KAFKA-4612: - Thank you so much! That all makes perfect sense. > Simple

[jira] [Commented] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

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

[GitHub] kafka pull request #2346: KAFKA-4619: Dissallow to output records with unkno...

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/2346 KAFKA-4619: Dissallow to output records with unknown keys in TransformValues You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka

[jira] [Commented] (KAFKA-4612) Simple Kafka Streams app causes "ClassCastException: java.lang.String cannot be cast to [B"

[ https://issues.apache.org/jira/browse/KAFKA-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819174#comment-15819174 ] Matthias J. Sax commented on KAFKA-4612: If you add {{.through()}} there will be not internally

Re: [VOTE] KIP-107: Add purgeDataBefore() API in AdminClient

Sorry for the duplicated email. It seems that gmail will put the voting email in this thread if I simply replace DISCUSS with VOTE in the subject. On Wed, Jan 11, 2017 at 12:57 PM, Dong Lin wrote: > Hi all, > > It seems that there is no further concern with the KIP-107. At

[VOTE] KIP-107 Add purgeDataBefore() API in AdminClient

Hi all, It seems that there is no further concern with the KIP-107. At this point we would like to start the voting process. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP-107 %3A+Add+purgeDataBefore%28%29+API+in+AdminClient. Thanks, Dong

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4064: --- Fix Version/s: (was: 0.10.2.0) 0.10.3.0 > Add support for infinite

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4064: --- Affects Version/s: 0.10.2.0 > Add support for infinite endpoints for range queries in Kafka

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4064: --- Labels: needs-kip (was: ) > Add support for infinite endpoints for range queries in Kafka

[jira] [Updated] (KAFKA-4064) Add support for infinite endpoints for range queries in Kafka Streams KV stores

[ https://issues.apache.org/jira/browse/KAFKA-4064?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-4064: --- Assignee: Xavier Léauté (was: Roger Hoover) > Add support for infinite endpoints for range

[VOTE] KIP-107: Add purgeDataBefore() API in AdminClient

Hi all, It seems that there is no further concern with the KIP-107. At this point we would like to start the voting process. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP- 107%3A+Add+purgeDataBefore%28%29+API+in+AdminClient. Thanks, Dong

[VOTE] KIP-107: Add purgeDataBefore() API in AdminClient

Hi all, It seems that there is no further concern with the KIP-107. At this point we would like to start the voting process. The KIP can be found at https://cwiki.apache.org/confluence/display/KAFKA/KIP-107%3A+Add+purgeDataBefore%28%29+API+in+AdminClient . Thanks, Dong

[jira] [Commented] (KAFKA-4612) Simple Kafka Streams app causes "ClassCastException: java.lang.String cannot be cast to [B"

[ https://issues.apache.org/jira/browse/KAFKA-4612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819134#comment-15819134 ] Kurt Ostfeld commented on KAFKA-4612: - Thank you! You explained the issue, it makes perfect sense, and

[jira] [Created] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

Matthias J. Sax created KAFKA-4619: -- Summary: Dissallow to output records with unknown keys in TransformValues Key: KAFKA-4619 URL: https://issues.apache.org/jira/browse/KAFKA-4619 Project: Kafka

[jira] [Work started] (KAFKA-4619) Dissallow to output records with unknown keys in TransformValues

[ https://issues.apache.org/jira/browse/KAFKA-4619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-4619 started by Matthias J. Sax. -- > Dissallow to output records with unknown keys in TransformValues >

[jira] [Resolved] (KAFKA-4611) Support custom authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] mahendiran chandrasekar resolved KAFKA-4611. Resolution: Workaround Fix Version/s: 0.10.2.0 > Support custom

[jira] [Commented] (KAFKA-4611) Support custom authentication mechanism

[ https://issues.apache.org/jira/browse/KAFKA-4611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15819067#comment-15819067 ] mahendiran chandrasekar commented on KAFKA-4611: I think changes in 0.10.2.0 are pretty

Re: [ANNOUNCE] New committer: Grant Henke

Congrats! Eno > On 11 Jan 2017, at 20:06, Ben Stopford wrote: > > Congrats Grant!! > On Wed, 11 Jan 2017 at 20:01, Ismael Juma wrote: > >> Congratulations Grant, well deserved. :) >> >> Ismael >> >> On 11 Jan 2017 7:51 pm, "Gwen Shapira"

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 nonbinding. We were bit by this in a production environment. On Wed, Jan 11, 2017 at 11:42 AM, Ian Wrigley wrote: > +1 (non-binding) > > > On Jan 11, 2017, at 11:33 AM, Jay Kreps wrote: > > > > +1 > > > > On Wed, Jan 11, 2017 at 10:56 AM, Ben Stopford

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

Thanks all. We can consider this accepted. B On Wed, 11 Jan 2017 at 19:49, Apurva Mehta wrote: > +1 (non-binding) > > On Wed, Jan 11, 2017 at 11:45 AM, Gwen Shapira wrote: > > > +1 > > > > On Wed, Jan 11, 2017 at 10:56 AM, Ben Stopford

Re: [ANNOUNCE] New committer: Grant Henke

Congrats Grant!! On Wed, 11 Jan 2017 at 20:01, Ismael Juma wrote: > Congratulations Grant, well deserved. :) > > Ismael > > On 11 Jan 2017 7:51 pm, "Gwen Shapira" wrote: > > > The PMC for Apache Kafka has invited Grant Henke to join as a > > committer and

Re: [ANNOUNCE] New committer: Grant Henke

Congratulations Grant, well deserved. :) Ismael On 11 Jan 2017 7:51 pm, "Gwen Shapira" wrote: > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88 patches, 90 code reviews,

[jira] [Resolved] (KAFKA-3715) Higher granularity streams metrics

[ https://issues.apache.org/jira/browse/KAFKA-3715?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-3715. -- Resolution: Fixed > Higher granularity streams metrics > --- >

Re: [ANNOUNCE] New committer: Grant Henke

Congrats! On Wed, Jan 11, 2017 at 11:57 AM, Sriram Subramanian wrote: > Congratulations Grant! > > On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shapira wrote: > > > The PMC for Apache Kafka has invited Grant Henke to join as a > > committer and we are pleased to

Re: [ANNOUNCE] New committer: Grant Henke

Congrats Grant! --Vahid From: Sriram Subramanian To: us...@kafka.apache.org Cc: dev@kafka.apache.org, priv...@kafka.apache.org Date: 01/11/2017 11:58 AM Subject:Re: [ANNOUNCE] New committer: Grant Henke Congratulations Grant! On Wed, Jan 11, 2017 at

Re: [ANNOUNCE] New committer: Grant Henke

Congratulations Grant! On Wed, Jan 11, 2017 at 11:51 AM, Gwen Shapira wrote: > The PMC for Apache Kafka has invited Grant Henke to join as a > committer and we are pleased to announce that he has accepted! > > Grant contributed 88 patches, 90 code reviews, countless great >

Re: [DISCUSS] KIP-107: Add purgeDataBefore() API in AdminClient

Hi Mayuresh, low_watermark will be updated when log retention fires on the broker. It may also be updated on the follower when follower receives FetchResponse from leader; and it may be updated on the leader when leader receives PurgeRequest from admin client. Thanks, Dong On Wed, Jan 11, 2017

[ANNOUNCE] New committer: Grant Henke

The PMC for Apache Kafka has invited Grant Henke to join as a committer and we are pleased to announce that he has accepted! Grant contributed 88 patches, 90 code reviews, countless great comments on discussions, a much-needed cleanup to our protocol and the on-going and critical work on the

Re: [VOTE] KIP-106 - Default unclean.leader.election.enabled True => False

+1 (non-binding) On Wed, Jan 11, 2017 at 11:45 AM, Gwen Shapira wrote: > +1 > > On Wed, Jan 11, 2017 at 10:56 AM, Ben Stopford wrote: > > Looks like there was a good consensus on the discuss thread for KIP-106 > so > > lets move to a vote. > > > > Please

  1   2   >