[jira] [Created] (KAFKA-6027) System test failure: LogDirFailureTest

Ismael Juma created KAFKA-6027: -- Summary: System test failure: LogDirFailureTest Key: KAFKA-6027 URL: https://issues.apache.org/jira/browse/KAFKA-6027 Project: Kafka Issue Type: Bug

[DISCUSS] KIP-208: Add SSL support to Kafka Connect REST interface

Hi, I would like to start a discussion about KIP-208: Add SSL support to Kafka Connect REST interface ( https://cwiki.apache.org/confluence/display/KAFKA/KIP-208%3A+Add+SSL+support+to+Kafka+Connect+REST+interface ). I think this would be useful feature to improve the security of Kafka Connect.

[jira] [Created] (KAFKA-6026) Timeout on KafkaFuture not honoured

Bart De Vylder created KAFKA-6026: - Summary: Timeout on KafkaFuture not honoured Key: KAFKA-6026 URL: https://issues.apache.org/jira/browse/KAFKA-6026 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request #4043: the rate calculation is wrong somehow, will make s...

GitHub user lisa2lisa opened a pull request: https://github.com/apache/kafka/pull/4043 the rate calculation is wrong somehow, will make some heavy read and write log stop compaction You can merge this pull request into a Git repository by running: $ git pull

[jira] [Resolved] (KAFKA-5774) WorkerSinkTask failure exception should include cause

[ https://issues.apache.org/jira/browse/KAFKA-5774?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Randall Hauch resolved KAFKA-5774. -- Resolution: Fixed Fix Version/s: 1.0.0 Indeed, this was [fixed with this

[GitHub] kafka pull request #4044: KAFKA-6026: Fix for indefinite wait in KafkaFuture...

GitHub user bartdevylder opened a pull request: https://github.com/apache/kafka/pull/4044 KAFKA-6026: Fix for indefinite wait in KafkaFutureImpl Not passing 0 to wait in KafkaFuture implementation. The case where the timeout argument is 0 is already taken care of in the definition

Re: [DISCUSS] KIP-208: Add SSL support to Kafka Connect REST interface

For rest.ssl.clientAuth , I don't find counterpart in existing code. Can you add explanation on the KIP ? Thanks On Mon, Oct 9, 2017 at 8:25 AM, Jakub Scholz wrote: > Hi, > > I would like to start a discussion about KIP-208: Add SSL support to Kafka > Connect REST interface (

Re: [DISCUSS] KIP-208: Add SSL support to Kafka Connect REST interface

Sorry, that is a typo. It should be rest.ssl.client.auth and it should correspond to the ssl.client.auth option in the broker. The rest.ssl.client.auth option would support values of required, requested and none (none being the default). It will control whether: * the connecting client is

[GitHub] kafka-site issue #92: Redesign of Streams page - includes video & customer l...

Github user guozhangwang commented on the issue: https://github.com/apache/kafka-site/pull/92 Merged to asf-site. ---

[GitHub] kafka-site pull request #92: Redesign of Streams page - includes video & cus...

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

[GitHub] kafka pull request #3506: KAFKA-5565. Add a broker metric specifying the num...

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

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

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

WIKI access request

If someone could please add my user clebertsuconic with autorization to create pages. I am trying to follow the process lined up here: https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improvement+Proposals Thanks

Re: [VOTE] KIP-203: Add toLowerCase support to sasl.kerberos.principal.to.local rule

I'm bumping this up to get some attention :) On Wed, Sep 27, 2017 at 8:46 PM, Tom Bentley wrote: > +1 (nonbinding) > > On 27 September 2017 at 16:10, Manikumar > wrote: > > > Hi All, > > > > I'd like to start the vote on KIP-203. Details are

[GitHub] kafka-site pull request #92: Redesign of Streams page - includes video & cus...

Github user guozhangwang commented on a diff in the pull request: https://github.com/apache/kafka-site/pull/92#discussion_r143525624 --- Diff: 0110/streams/index.html --- @@ -1,275 +1,311 @@ - - - + Licensed to

[GitHub] kafka pull request #3953: KAFKA-5541: Streams should not re-throw if suspend...

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

[jira] [Created] (KAFKA-6029) Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest

Jiangjie Qin created KAFKA-6029: --- Summary: Controller should wait for the leader migration to finish before ack a ControlledShutdownRequest Key: KAFKA-6029 URL: https://issues.apache.org/jira/browse/KAFKA-6029

[jira] [Created] (KAFKA-6028) Improve the quota throttle communication.

Jiangjie Qin created KAFKA-6028: --- Summary: Improve the quota throttle communication. Key: KAFKA-6028 URL: https://issues.apache.org/jira/browse/KAFKA-6028 Project: Kafka Issue Type:

[GitHub] kafka-site pull request #93: Adding correct image URL for twitter

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/93 Adding correct image URL for twitter You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site asf-site Alternatively you can

[GitHub] kafka pull request #4046: KAFKA-5541: minor follow-up

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4046 KAFKA-5541: minor follow-up You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka kafka-5541-minor-follow-up Alternatively you can review

[GitHub] kafka-site pull request #93: Adding correct image URL for twitter

Github user manjuapu closed the pull request at: https://github.com/apache/kafka-site/pull/93 ---

[GitHub] kafka-site pull request #94: Correcting video pause & clicks

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/94 Correcting video pause & clicks You can merge this pull request into a Git repository by running: $ git pull https://github.com/manjuapu/kafka-site asf-site Alternatively you can review

[GitHub] kafka-site issue #94: Correcting video pause & clicks

Github user manjuapu commented on the issue: https://github.com/apache/kafka-site/pull/94 @guozhangwang please review this. ---

[GitHub] kafka pull request #4047: MINOR: Factor out some common group/transactional ...

GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/4047 MINOR: Factor out some common group/transactional fields in request objects You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka

[GitHub] kafka-site pull request #94: Correcting video pause & clicks

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

[jira] [Created] (KAFKA-6030) Integer overflow in log cleaner cleanable ratio computation

Jason Gustafson created KAFKA-6030: -- Summary: Integer overflow in log cleaner cleanable ratio computation Key: KAFKA-6030 URL: https://issues.apache.org/jira/browse/KAFKA-6030 Project: Kafka

[GitHub] kafka pull request #4047: MINOR: Factor out some common group/transactional ...

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

[jira] [Created] (KAFKA-6031) Expose standby replicas endpoints in StreamsMetadata

Stanislav Chizhov created KAFKA-6031: Summary: Expose standby replicas endpoints in StreamsMetadata Key: KAFKA-6031 URL: https://issues.apache.org/jira/browse/KAFKA-6031 Project: Kafka

[jira] [Created] (KAFKA-6032) Unit Tests should be independent of locale settings

Gilles Degols created KAFKA-6032: Summary: Unit Tests should be independent of locale settings Key: KAFKA-6032 URL: https://issues.apache.org/jira/browse/KAFKA-6032 Project: Kafka Issue

[GitHub] kafka pull request #3266: WIP: KAFKA-5403: Transaction system test consumer ...

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

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

See Changes: [jason] MINOR: Factor out some common group/transactional fields in request -- [...truncated 370.58 KB...] kafka.server.ServerGenerateBrokerIdTest >

[GitHub] kafka pull request #4048: MINOR: fix EOS test race condition

GitHub user mjsax opened a pull request: https://github.com/apache/kafka/pull/4048 MINOR: fix EOS test race condition You can merge this pull request into a Git repository by running: $ git pull https://github.com/mjsax/kafka fix-eos-test-race-condition Alternatively you can

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

See Changes: [jason] MINOR: Factor out some common group/transactional fields in request -- [...truncated 2.90 MB...] org.apache.kafka.common.security.JaasContextTest >

[GitHub] kafka pull request #4043: the rate calculation is wrong somehow, will make s...

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

[jira] [Resolved] (KAFKA-6030) Integer overflow in log cleaner cleanable ratio computation

[ https://issues.apache.org/jira/browse/KAFKA-6030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson resolved KAFKA-6030. Resolution: Fixed Issue resolved by pull request 4043

[jira] [Created] (KAFKA-6033) Kafka Streams does not work with musl-libc (alpine linux)

Jeffrey Zampieron created KAFKA-6033: Summary: Kafka Streams does not work with musl-libc (alpine linux) Key: KAFKA-6033 URL: https://issues.apache.org/jira/browse/KAFKA-6033 Project: Kafka

Build failed in Jenkins: kafka-trunk-jdk9 #112

See Changes: [jason] KAFKA-6030; Fix Integer overflow in cleanable ratio computation -- [...truncated 1.20 MB...] kafka.api.LegacyAdminClientTest >

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

See Changes: [jason] KAFKA-6030; Fix Integer overflow in cleanable ratio computation -- [...truncated 371.39 KB...] kafka.security.auth.SimpleAclAuthorizerTest >

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

See

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

See

[jira] [Created] (KAFKA-6034) Streams DSL to Processor Topology Translation Improvements

Guozhang Wang created KAFKA-6034: Summary: Streams DSL to Processor Topology Translation Improvements Key: KAFKA-6034 URL: https://issues.apache.org/jira/browse/KAFKA-6034 Project: Kafka

[jira] [Created] (KAFKA-6035) Avoid creating changelog topics for state stores that are directly piped to a sink topic

Guozhang Wang created KAFKA-6035: Summary: Avoid creating changelog topics for state stores that are directly piped to a sink topic Key: KAFKA-6035 URL: https://issues.apache.org/jira/browse/KAFKA-6035

[jira] [Created] (KAFKA-6036) Enable logical materialization to physical materialization

Guozhang Wang created KAFKA-6036: Summary: Enable logical materialization to physical materialization Key: KAFKA-6036 URL: https://issues.apache.org/jira/browse/KAFKA-6036 Project: Kafka

[jira] [Created] (KAFKA-6037) Make Sub-topology Parallelism Tunable

Guozhang Wang created KAFKA-6037: Summary: Make Sub-topology Parallelism Tunable Key: KAFKA-6037 URL: https://issues.apache.org/jira/browse/KAFKA-6037 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-6038) Repartition topics could be much more transient

Guozhang Wang created KAFKA-6038: Summary: Repartition topics could be much more transient Key: KAFKA-6038 URL: https://issues.apache.org/jira/browse/KAFKA-6038 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-6039) Improve TaskAssignor to be more load balanced

Guozhang Wang created KAFKA-6039: Summary: Improve TaskAssignor to be more load balanced Key: KAFKA-6039 URL: https://issues.apache.org/jira/browse/KAFKA-6039 Project: Kafka Issue Type:

[GitHub] kafka pull request #4044: KAFKA-6026: Fix for indefinite wait in KafkaFuture...

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

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

See

[GitHub] kafka pull request #4049: [KAFKA-5212] Consumer ListOffsets request can star...

GitHub user ConcurrencyPractitioner opened a pull request: https://github.com/apache/kafka/pull/4049 [KAFKA-5212] Consumer ListOffsets request can starve group heartbeats Through the identification of the poll method in ConsumerCoordinator as the place where the heartbeat is sent,

Jenkins build is back to normal : kafka-trunk-jdk9 #113

See

[GitHub] kafka-site pull request #95: Change apache-kafka image permission as image n...

GitHub user manjuapu opened a pull request: https://github.com/apache/kafka-site/pull/95 Change apache-kafka image permission as image not appearing in twitter @guozhangwang Please review You can merge this pull request into a Git repository by running: $ git pull

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

I've added RequestedTopicState, as discussed in my last email. I've also added a paragraph to the migration plan about old clients making policy-violating delete topics or delete records request. If no further comments a forthcoming in the next day or two then I will start a vote. Thanks, Tom

Re: [DISCUSS] KIP-171: Extend Consumer Group Reset Offset for Stream Application

Matthias, Thanks for the heads up! I think the main dependency is from `StreamResseter` to `ConsumerGroupCommand` class to actually reuse `#reset-offsets` functionality. Not sure what would be the better way to remove it. To expose commands (e.g. `ConsumerGroupCommand`) as part of AdminClient,