[1/2] kafka git commit: KAFKA-4591; Create Topic Policy (KIP-108)

Repository: kafka Updated Branches: refs/heads/trunk bc61d9bee -> da57bc27e http://git-wip-us.apache.org/repos/asf/kafka/blob/da57bc27/streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsKafkaClient.java -

[2/2] kafka git commit: KAFKA-4591; Create Topic Policy (KIP-108)

KAFKA-4591; Create Topic Policy (KIP-108) Author: Ismael Juma Reviewers: Apurva Mehta , Gwen Shapira , Jason Gustafson Closes #2361 from ijuma/kafka-4591-create-topic-policy Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commi

kafka git commit: KAFKA-3857; Additional log cleaner metrics

Repository: kafka Updated Branches: refs/heads/trunk c2d9b95f3 -> bc61d9bee KAFKA-3857; Additional log cleaner metrics Fixes KAFKA-3857 Changes proposed in this pull request: An additional log cleaner metric has been added: time-since-last-run-ms: Time since the last log cleaner run, in mill

[2/2] kafka git commit: KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88)

KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88) Author: Vahid Hashemian Reviewers: Ismael Juma , Ewen Cheslack-Postava , Jason Gustafson Closes #2074 from vahidhashemian/KAFKA-3853 Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Com

[1/2] kafka git commit: KAFKA-3853; Extend OffsetFetch API to allow fetching all offsets for a consumer group (KIP-88)

Repository: kafka Updated Branches: refs/heads/trunk 88fdca26a -> c2d9b95f3 http://git-wip-us.apache.org/repos/asf/kafka/blob/c2d9b95f/core/src/test/scala/unit/kafka/coordinator/GroupMetadataManagerTest.scala -- diff --git a/c

kafka git commit: KAFKA-4381: Add per partition lag metrics to the consumer

Repository: kafka Updated Branches: refs/heads/trunk e90db3e3a -> 88fdca26a KAFKA-4381: Add per partition lag metrics to the consumer Author: Jiangjie Qin Reviewers: Ismael Juma , Ewen Cheslack-Postava Closes #2329 from becketqin/KAFKA-4381 Project: http://git-wip-us.apache.org/repos/as

kafka git commit: MINOR: Remove unnecessary store info from TopologyBuilder

Repository: kafka Updated Branches: refs/heads/trunk fc0d612b0 -> e90db3e3a MINOR: Remove unnecessary store info from TopologyBuilder This PR is extracted from https://github.com/apache/kafka/pull/2333 as an incremental fix to ease the reviewing: 1. Removed `storeToProcessorNodeMap` from Pro

kafka git commit: KAFKA-3739: Add no-arg constructor for WindowedSerdes in Streams

Repository: kafka Updated Branches: refs/heads/trunk d1956d4b6 -> fc0d612b0 KAFKA-3739: Add no-arg constructor for WindowedSerdes in Streams Add default constructor for library provided serdes Author: huxi Author: amethystic Reviewers: Guozhang Wang Closes #2308 from amethystic/kafka373

kafka git commit: HOTFIX: Added another broker to smoke test

Repository: kafka Updated Branches: refs/heads/trunk f6fee34a2 -> d1956d4b6 HOTFIX: Added another broker to smoke test Author: Eno Thereska Reviewers: Guozhang Wang Closes #2362 from enothereska/hotfix-smoke-test-2-brokers Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit

kafka git commit: KAFKA-4627; Fix timing issue in consumer close tests

Repository: kafka Updated Branches: refs/heads/trunk 6496271a1 -> f6fee34a2 KAFKA-4627; Fix timing issue in consumer close tests Author: Rajini Sivaram Reviewers: Apurva Mehta , Jason Gustafson Closes #2367 from rajinisivaram/KAFKA-4627 Project: http://git-wip-us.apache.org/repos/asf/ka

kafka git commit: MINOR: Remove unneeded client used API lists

Repository: kafka Updated Branches: refs/heads/trunk 7a61ce4cf -> 6496271a1 MINOR: Remove unneeded client used API lists Author: Jason Gustafson Reviewers: Ewen Cheslack-Postava , Gwen Shapira , Apurva Mehta , Ismael Juma Closes #2372 from hachikuji/minor-cleanup-used-apis Project: htt

kafka git commit: MINOR: Cluster file generator should produce valid json

Repository: kafka Updated Branches: refs/heads/trunk d25671884 -> 7a61ce4cf MINOR: Cluster file generator should produce valid json This way, if the ${KAFKA_NUM_CONTAINERS} is changed in docker/run_tests.sh, the json is still valid Author: Emanuele Cesena Reviewers: Ewen Cheslack-Postava

[2/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/main/scala/kafka/server/KafkaConfig.scala -- diff --git a/core/src/main/scala/kafka/server/KafkaConfig.scala b/core/src/main/scala/kafka/server/KafkaConfig.scala

[3/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

KAFKA-4565; Separation of Internal and External traffic (KIP-103) Author: Ismael Juma Reviewers: Gwen Shapira , Jason Gustafson Closes #2354 from ijuma/kafka-4565-separation-of-internal-and-external-traffic Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.

[1/3] kafka git commit: KAFKA-4565; Separation of Internal and External traffic (KIP-103)

Repository: kafka Updated Branches: refs/heads/trunk 80d6c64c1 -> d25671884 http://git-wip-us.apache.org/repos/asf/kafka/blob/d2567188/core/src/test/scala/unit/kafka/server/AdvertiseBrokerTest.scala -- diff --git a/core/src/tes

kafka git commit: KAFKA-4626; Add KafkaConsumer#close change to upgrade notes

Repository: kafka Updated Branches: refs/heads/trunk 8d9d84790 -> 80d6c64c1 KAFKA-4626; Add KafkaConsumer#close change to upgrade notes Author: Rajini Sivaram Reviewers: Ismael Juma , Jason Gustafson Closes #2366 from rajinisivaram/KAFKA-4626 Project: http://git-wip-us.apache.org/repos/a

kafka git commit: KAFKA-4581; Fail early if multiple client login modules in sasl.jaas.config

Repository: kafka Updated Branches: refs/heads/trunk 2eb32d6a7 -> 8d9d84790 KAFKA-4581; Fail early if multiple client login modules in sasl.jaas.config Validate and fail client connection if multiple login modules are specified in sasl.jaas.config to avoid harder-to-debug authentication failu