[GitHub] kafka pull request #4007: MINOR: Java 9 version handling improvements

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4007 ---

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Thanks Tom, looks got to me and KIP-201 could supersede KIP-170 but could you please add a missing motivation bullet that was behind KIP-170: introducing ClusterState to allow validation of create/alter topic request not just against the request metadata but also against the current amount of

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

See Changes: [ismael] MINOR: Java 9 version handling improvements -- [...truncated 1.39 MB...] org.apache.kafka.common.security.plain.PlainSaslServerTest > noAuthorizati

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Thanks Edoardo, I've added that motivation to the KIP. KIP-201 doesn't address two points raised in KIP-170: Adding a validationOnly flag to DeleteTopicRequest and adding an error message to DeleteTopicResponse. Since those are not policy-related I think they're best left out of KIP-201. I suppos

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Those two points are related to policies in the following sense: 1. A policy that can't send errors to clients is much less useful 2. Testing policies is much easier with `validateOnly` Ismael On Wed, Oct 4, 2017 at 9:20 AM, Tom Bentley wrote: > Thanks Edoardo, > > I've added that motivation t

Re: [DISCUSS] KIP-201: Rationalising Policy interfaces

Good point. Then I guess I can do those items too. I would also need to do the same changes for DeleteRecordsRequest and Response. On 4 October 2017 at 10:37, Ismael Juma wrote: > Those two points are related to policies in the following sense: > > 1. A policy that can't send errors to clients i

[jira] [Created] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

Jakub Scholz created KAFKA-6008: --- Summary: Kafka Connect: Unsanitized workerID causes exception during startup Key: KAFKA-6008 URL: https://issues.apache.org/jira/browse/KAFKA-6008 Project: Kafka

[GitHub] kafka pull request #4012: KAFKA-6008: Sanitize the Kafka Connect workerId be...

GitHub user scholzj opened a pull request: https://github.com/apache/kafka/pull/4012 KAFKA-6008: Sanitize the Kafka Connect workerId before passing it to AppInfoParser You can merge this pull request into a Git repository by running: $ git pull https://github.com/scholzj/kafk

[GitHub] kafka pull request #4013: KAFKA-4764: Upgrade notes for authentication failu...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4013 KAFKA-4764: Upgrade notes for authentication failure handling (KIP-152) You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafk

[GitHub] kafka pull request #4014: KAFKA-5738: Upgrade note for cumulative count metr...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4014 KAFKA-5738: Upgrade note for cumulative count metric (KIP-187) You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka MINOR-u

[GitHub] kafka pull request #4015: KAFKA-6004: Allow authentication providers to over...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4015 KAFKA-6004: Allow authentication providers to override error message You can merge this pull request into a Git repository by running: $ git pull https://github.com/rajinisivaram/kafka K

[GitHub] kafka pull request #4016: MINOR: Simplify log cleaner and fix compiler warni...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4016 MINOR: Simplify log cleaner and fix compiler warnings - Simplify LogCleaner.cleanSegments and add comment regarding thread unsafe usage of `LogSegment.append`. This was a result of investigating

[GitHub] kafka pull request #4013: KAFKA-4764: Upgrade notes for authentication failu...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4013 ---

[GitHub] kafka pull request #4014: KAFKA-5738: Upgrade note for cumulative count metr...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4014 ---

[jira] [Resolved] (KAFKA-5842) QueryableStateIntegrationTest may fail with JDK 7

[ https://issues.apache.org/jira/browse/KAFKA-5842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ted Yu resolved KAFKA-5842. --- Resolution: Cannot Reproduce > QueryableStateIntegrationTest may fail with JDK 7 > ---

[GitHub] kafka pull request #2150: KAFKA-4416: Add a `--group` option to console cons...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/2150 ---

[GitHub] kafka pull request #3863: MINOR: Use SecurityProtocol in AuthenticationConte...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3863 ---

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

See

Re: [DISCUSS] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

Currently the KIP's scope is only topics that don't yet exist, and we have to cognizant of race conditions between tasks with the same connector. I think it is worthwhile to consider whether the KIP's scope should expand to also address *existing* partitions, though it may not be appropriate to hav

[GitHub] kafka pull request #3988: KAFKA-5967 Ineffective check of negative value in ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3988 ---

[jira] [Resolved] (KAFKA-5569) Document any changes from this task

[ https://issues.apache.org/jira/browse/KAFKA-5569?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax resolved KAFKA-5569. Resolution: Not A Problem There is nothing to document for 1.0 release, besides KIP-161 that

[jira] [Resolved] (KAFKA-6004) Enable custom authentication plugins to return error messages to clients

[ https://issues.apache.org/jira/browse/KAFKA-6004?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6004. --- Resolution: Fixed Issue resolved by pull request 4015 [https://github.com/apache/kafka/pull/40

[GitHub] kafka pull request #4015: KAFKA-6004: Allow authentication providers to over...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4015 ---

[GitHub] kafka pull request #4016: MINOR: Simplify log cleaner and fix compiler warni...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4016 ---

[jira] [Created] (KAFKA-6009) Fix formatting of autogenerated docs tables

Ewen Cheslack-Postava created KAFKA-6009: Summary: Fix formatting of autogenerated docs tables Key: KAFKA-6009 URL: https://issues.apache.org/jira/browse/KAFKA-6009 Project: Kafka Iss

[GitHub] kafka pull request #3937: KAFKA-5856 AdminClient.createPartitions() follow u...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3937 ---

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

See Changes: [rajinisivaram] KAFKA-5738; Upgrade note for cumulative count metric (KIP-187) [jason] KAFKA-4416; Add a `--group` option to console consumer [jason] MINOR: Use SecurityProtocol in AuthenticationCo

[jira] [Resolved] (KAFKA-5990) Add generated documentation for Connect metrics

[ https://issues.apache.org/jira/browse/KAFKA-5990?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-5990. -- Resolution: Fixed Issue resolved by pull request 3987 [https://github.com/apache

[jira] [Resolved] (KAFKA-4890) State directory being deleted when another thread holds the lock

[ https://issues.apache.org/jira/browse/KAFKA-4890?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Damian Guy resolved KAFKA-4890. --- Resolution: Duplicate > State directory being deleted when another thread holds the lock > ---

[GitHub] kafka pull request #3987: KAFKA-5990: Enable generation of metrics docs for ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3987 ---

[jira] [Created] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

Ismael Juma created KAFKA-6010: -- Summary: Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data Key: KAFKA-6010 URL: https://issues.apache.org/jira/browse/KAFKA-6010 Project: Kafka

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

See Changes: [jason] KAFKA-4416; Add a `--group` option to console consumer [jason] MINOR: Use SecurityProtocol in AuthenticationContext -- [...truncated 1.81 MB...] org

[jira] [Created] (KAFKA-6011) AppInfoParser should only use metrics API and should not register JMX mbeans directly

Ewen Cheslack-Postava created KAFKA-6011: Summary: AppInfoParser should only use metrics API and should not register JMX mbeans directly Key: KAFKA-6011 URL: https://issues.apache.org/jira/browse/KAFKA-601

[GitHub] kafka pull request #4017: Rename streams tutorial and quickstart

GitHub user joel-hamill opened a pull request: https://github.com/apache/kafka/pull/4017 Rename streams tutorial and quickstart Write your own Streams Applications -> Tutorial: Write a Streams Application Play with a Streams Application -> Run the Streams Demo Application You c

Jenkins build is back to normal : kafka-0.11.0-jdk7 #315

See

[GitHub] kafka pull request #3862: MINOR: Dev guide fixup

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3862 ---

[GitHub] kafka pull request #3956: KAFKA-5970: Use ReentrantLock for delayed operatio...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3956 ---

[jira] [Resolved] (KAFKA-6008) Kafka Connect: Unsanitized workerID causes exception during startup

[ https://issues.apache.org/jira/browse/KAFKA-6008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-6008. -- Resolution: Fixed Issue resolved by pull request 4012 [https://github.com/apache

[GitHub] kafka pull request #4012: KAFKA-6008: Sanitize the Kafka Connect workerId be...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4012 ---

[GitHub] kafka pull request #4018: KAFKA-6010: Relax record conversion time test to a...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4018 KAFKA-6010: Relax record conversion time test to avoid build failure For record conversion tests, check time >=0 since conversion times may be too small to be measured accurately. Since defaul

[GitHub] kafka pull request #3984: MINOR: update streams quickstart for KIP-182

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3984 ---

Re: [DISCUSS] URIs on Producer and Consumer

Ping??? Any thoughts? Or anyone can help me with write access to the Wiki so I can start a KIP discussion? my userID is clebert.suco...@gmail.com On Tue, Oct 3, 2017 at 2:45 PM, Clebert Suconic wrote: > I believe I need write access to the WIKI Page: > > > https://cwiki.apache.org/confluence/

[GitHub] kafka pull request #4006: MINOR: JavaDoc improvements for new state store AP...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4006 ---

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

See

[GitHub] kafka pull request #4019: KAFKA-6011 AppInfoParser should only use metrics A...

GitHub user tedyu opened a pull request: https://github.com/apache/kafka/pull/4019 KAFKA-6011 AppInfoParser should only use metrics API and should not register JMX mbeans directly Added app ID to metrics API. The JMX can be dropped post 1.0.0 You can merge this pull reques

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

See

Re: integration between pull request and JIRA

The only thing missing is that the contributor needs to watch the JIRA after sending out PR - otherwise he / she may miss comments on the JIRA (but not on PR). On Wed, Sep 6, 2017 at 12:27 PM, Matthias J. Sax wrote: > You can subscribe to single PR if you want, too. (That actually happens, > whe

[GitHub] kafka pull request #4020: KAFKA-6003: Accept appends on replicas and when re...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/4020 KAFKA-6003: Accept appends on replicas and when rebuilding the log unconditionally This is a port of #4004 for the 0.11.0 branch. With this patch so that we _only_ validate appends which or

[GitHub] kafka pull request #4001: KAFKA-6001: remove from Materializ...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/4001 ---

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

See Changes: [me] KAFKA-5990: Enable generation of metrics docs for Connect (KIP-196) [wangguoz] MINOR: streams dev guide fixup [jason] KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid [me] KA

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

See Changes: [wangguoz] MINOR: streams dev guide fixup [jason] KAFKA-5970; Use ReentrantLock for delayed operation lock to avoid [me] KAFKA-6008: Sanitize the app id before creating app id metric [wangguoz] MI

Re: integration between pull request and JIRA

A contributor should have the JIRA assigned to him/herself and thus should get notification about JIRA comments too, as if the JIRA is assigned, one also watches the JIRA. -Matthias On 10/4/17 1:32 PM, Ted Yu wrote: > The only thing missing is that the contributor needs to watch the JIRA > afte

[jira] [Resolved] (KAFKA-6010) Transient failure: MemoryRecordsBuilderTest.convertToV1WithMixedV0AndV2Data

[ https://issues.apache.org/jira/browse/KAFKA-6010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-6010. --- Resolution: Fixed Fix Version/s: 1.0.0 Issue resolved by pull request 4018 [https://git

[GitHub] kafka pull request #4018: KAFKA-6010: Relax record conversion time test to a...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4018 ---

[GitHub] kafka pull request #4003: MINOR: add suppress warnings annotations

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4003 ---

[GitHub] kafka pull request #3740: MINOR: reduce logging to trace in NetworkClient wh...

Github user dguy closed the pull request at: https://github.com/apache/kafka/pull/3740 ---

[GitHub] kafka pull request #3966: KAFKA-5980: FailOnInvalidTimestamp does not log er...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3966 ---

[jira] [Resolved] (KAFKA-5977) Upgrade RocksDB dependency to legally acceptable version

[ https://issues.apache.org/jira/browse/KAFKA-5977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-5977. -- Resolution: Duplicate Marking as duplicate of KAFKA-5576. > Upgrade RocksDB dependency to legal

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

See

[GitHub] kafka pull request #4021: KAFKA-5972 Flatten SMT does not work with null val...

GitHub user shivsantham opened a pull request: https://github.com/apache/kafka/pull/4021 KAFKA-5972 Flatten SMT does not work with null values A bug in Flatten SMT while doing tests with different SMTs that are provided out-of-box. Flatten SMT does not work as expected with schemale

1.0.0 Branch Update

Hello Kafka developers, This is another update on the 1.0.0 release progress. We were planing to close the code freeze and make the first RC by today, but we are behind our schedule a bit. After making a pass over all the JIRAs to move non-blockers to the next release we still have 20 tickets ong

[GitHub] kafka-site pull request #88: Remove last commit

GitHub user joel-hamill opened a pull request: https://github.com/apache/kafka-site/pull/88 Remove last commit You can merge this pull request into a Git repository by running: $ git pull https://github.com/joel-hamill/kafka-site joel-hamill/backout-changess Alternatively yo

[GitHub] kafka-site pull request #88: Remove last commit

Github user joel-hamill closed the pull request at: https://github.com/apache/kafka-site/pull/88 ---

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

See

[GitHub] kafka-site issue #89: Back out changes to index

Github user joel-hamill commented on the issue: https://github.com/apache/kafka-site/pull/89 @guozhangwang ---

[GitHub] kafka-site pull request #89: Back out changes to index

GitHub user joel-hamill opened a pull request: https://github.com/apache/kafka-site/pull/89 Back out changes to index You can merge this pull request into a Git repository by running: $ git pull https://github.com/joel-hamill/kafka-site joel-hamill/backout-changes2 Alternati

Build failed in Jenkins: kafka-1.0.0-jdk7 #1

See -- [...truncated 368.16 KB...] kafka.server.epoch.LeaderEpochFileCacheTest > shouldUpdateSavedOffsetWhenOffsetToClearToIsBetweenEpochs PASSED kafka.server.epoch.LeaderEpochFileCacheTe

[jira] [Resolved] (KAFKA-5767) Kafka server should halt if IBP < 1.0.0 and there is log directory failure

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

[GitHub] kafka pull request #3718: KAFKA-5767; Kafka server should halt if IBP < 1.0....

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3718 ---

[GitHub] kafka pull request #3840: KAFKA-5879; Controller should read the latest IsrC...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/3840 ---

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

See Changes: [wangguoz] MINOR: add suppress warnings annotations in Streams API [wangguoz] KAFKA-5980: FailOnInvalidTimestamp does not log error [wangguoz] Bump up version to 1.1.0-SNAPSHOT ---

[jira] [Created] (KAFKA-6012) NoSuchElementException in markErrorMeter during TransactionsBounceTest

Ismael Juma created KAFKA-6012: -- Summary: NoSuchElementException in markErrorMeter during TransactionsBounceTest Key: KAFKA-6012 URL: https://issues.apache.org/jira/browse/KAFKA-6012 Project: Kafka

Re: [DISCUSS] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

I agree. I'm personally against increasing the partitions number, but RF would make sense. Same for configs, I'm okay with them being overriden. Maybe a "conflict" setting would make sense? Options: do nothing, throw exception, or apply? (default: do nothing - for safety) It'd be worth incl

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

See Changes: [junrao] KAFKA-5767; Kafka server should halt if IBP < 1.0.0 and there is log -- [...truncated 1.81 MB...] org.apache.kafka.streams.integration.KTableKTableJ

Re: [DISCUSS] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

Randall: bq. AdminClient currently allows changing the replication factory. By 'replication factory' did you mean 'replication factor' ? Cheers On Wed, Oct 4, 2017 at 9:58 AM, Randall Hauch wrote: > Currently the KIP's scope is only topics that don't yet exist, and we have > to cognizant of ra

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

See

[jira] [Created] (KAFKA-6013) Controller getting stuck

Ivan Babrou created KAFKA-6013: -- Summary: Controller getting stuck Key: KAFKA-6013 URL: https://issues.apache.org/jira/browse/KAFKA-6013 Project: Kafka Issue Type: Bug Affects Versions: 0.11

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

See

want to join this mail list

-- Chrysan Wu 联系方式：17717640807

Re: want to join this mail list

See https://kafka.apache.org/contact for instructions. 2017-10-04 19:31 GMT-07:00 吴晓菊 : > -- > > Chrysan Wu > 联系方式：17717640807 >

[jira] [Created] (KAFKA-6014) new consumer mirror maker halts after committing offsets to a deleted topic

Onur Karaman created KAFKA-6014: --- Summary: new consumer mirror maker halts after committing offsets to a deleted topic Key: KAFKA-6014 URL: https://issues.apache.org/jira/browse/KAFKA-6014 Project: Kafk

Re: [DISCUSS] KIP-158: Kafka Connect should allow source connectors to set topic-specific settings for new topics

Oops. Yes, I meant “replication factor”. > On Oct 4, 2017, at 7:18 PM, Ted Yu wrote: > > Randall: > bq. AdminClient currently allows changing the replication factory. > > By 'replication factory' did you mean 'replication factor' ? > > Cheers > >> On Wed, Oct 4, 2017 at 9:58 AM, Randall Hauc

[jira] [Created] (KAFKA-6015) NPE in RecordAccumulator

Apurva Mehta created KAFKA-6015: --- Summary: NPE in RecordAccumulator Key: KAFKA-6015 URL: https://issues.apache.org/jira/browse/KAFKA-6015 Project: Kafka Issue Type: Bug Affects Versions: 1.

[jira] [Created] (KAFKA-6016) Use the idempotent producer in the reassign_partitions_test

Apurva Mehta created KAFKA-6016: --- Summary: Use the idempotent producer in the reassign_partitions_test Key: KAFKA-6016 URL: https://issues.apache.org/jira/browse/KAFKA-6016 Project: Kafka Issu

[GitHub] kafka pull request #4004: KAFKA-6003: Accept appends on replicas uncondition...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/4004 ---

[GitHub] kafka pull request #4022: KAFKA-6015: Fix NullPointerExceptionInRecordAccumu...

GitHub user apurvam opened a pull request: https://github.com/apache/kafka/pull/4022 KAFKA-6015: Fix NullPointerExceptionInRecordAccumulator It is possible for batches with sequence numbers to be in the `deque` while at the same time the in flight batches in the `TransactionManager`

Jenkins build is back to normal : kafka-1.0-jdk7 #4

See