Re: [DISCUSS] KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability

Hey Colin, Thanks for the reply! Please see my comment inline. On Fri, Nov 24, 2017 at 9:39 PM, Colin McCabe wrote: > On Thu, Nov 23, 2017, at 18:35, Dong Lin wrote: > > Hey Colin, > > > > Thanks for the KIP! This is definitely useful when there are many idle > > partitions

Re: [DISCUSS] KIP-227: Introduce Incremental FetchRequests to Increase Partition Scalability

On Thu, Nov 23, 2017, at 18:35, Dong Lin wrote: > Hey Colin, > > Thanks for the KIP! This is definitely useful when there are many idle > partitions in the clusters. > > Just in case it is useful, I will provide some number here. We observe > that for a clsuter that have around 2.5k partitions

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

See

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

See

[GitHub] kafka pull request #4250: KAFKA-6261: Fix exception thrown by request loggin...

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

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

See Changes: [ismael] MINOR: Temporarily disable testLogStartOffsetCheckpoint -- [...truncated 1.44 MB...] kafka.zk.ZKPathTest > testMakeSurePersistsPathExists STARTED

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

See Changes: [ismael] MINOR: Temporarily disable testLogStartOffsetCheckpoint -- [...truncated 2.94 MB...] org.apache.kafka.common.security.JaasContextTest >

[GitHub] kafka pull request #4262: MINOR: Temporarily disable testLogStartOffsetCheck...

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

[jira] [Resolved] (KAFKA-6248) Enable configuration of internal topics of Kafka Streams applications

[ https://issues.apache.org/jira/browse/KAFKA-6248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Tim Van Laer resolved KAFKA-6248. - Resolution: Not A Problem As this is supported in Kafka Streams 1.0.0, I close the stream. >

Wiki permissions

Hi, Could I get the permissions to create pages on the Kafka confluence ? I would like the submit a KIP. My wiki id is Jonathan Skrzypek Regards, Jonathan Skrzypek Middleware Engineering Messaging Engineering Goldman Sachs International Christchurch Court - 10-15 Newgate Street London EC1A 7HD

[GitHub] kafka pull request #4263: KAFKA-6241: Enable dynamic updates of broker SSL k...

GitHub user rajinisivaram opened a pull request: https://github.com/apache/kafka/pull/4263 KAFKA-6241: Enable dynamic updates of broker SSL keystore Enable dynamic broker configuration (see KIP-225 for details). Includes - Base implementation to allow specific broker configs

[GitHub] kafka pull request #4262: MINOR: Temporarily disable testLogStartOffsetCheck...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4262 MINOR: Temporarily disable testLogStartOffsetCheckpoint It's failing often and it seems like there are multiple reasons. PR #4238 will re-enable it. ### Committer Checklist (excluded from

[GitHub] kafka pull request #4261: MINOR: Avoid intermediate strings when parsing/dec...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/4261 MINOR: Avoid intermediate strings when parsing/decoding ZK JSON Also: - Fix bug in result type of `createSequentialPersistentPath` - Remove duplicated code from `ReplicationUtils` - Move

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

See Changes: [ismael] KAFKA-6074; Use ZookeeperClient in ReplicaManager and Partition -- [...truncated 400.89 KB...] kafka.security.auth.ResourceTypeTest > testFromString

[GitHub] kafka pull request #4254: KAFKA-6074 Use ZookeeperClient in ReplicaManager a...

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

Re: [DISCUSS]: KIP-159: Introducing Rich functions to Streams

Cleary we show the oldValue to the user. We have to, because we filter after the store. https://github.com/axbaretto/kafka/blob/master/streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java#L96 I cannot help you following this. It is really obvious and I am running