[1/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs

2016-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk eba0ede87 -> 69ebf6f7b http://git-wip-us.apache.org/repos/asf/kafka/blob/69ebf6f7/streams/src/test/java/org/apache/kafka/streams/integration/InternalTopicIntegrationTest.java

[2/2] kafka git commit: KAFKA-3595: window stores use compact, delete config for changelogs

2016-09-07 Thread guozhang
KAFKA-3595: window stores use compact,delete config for changelogs changelogs of window stores now configure cleanup.policy=compact,delete with retention.ms set to window maintainMs + StreamsConfig.WINDOW_STORE_CHANGE_LOG_ADDITIONAL_RETENTION_MS_CONFIG StoreChangeLogger produces messages with

kafka git commit: KAFKA-4123: Queryable State returning null for key before all stores in instance have been initialized

2016-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk ca3f3a492 -> eba0ede87 KAFKA-4123: Queryable State returning null for key before all stores in instance have been initialized Mark the store as open after the DB has been restored from the changelog. Only add the store to the map in

kafka git commit: MINOR: Document that Connect topics should use compaction

2016-09-07 Thread jgus
Repository: kafka Updated Branches: refs/heads/trunk 3a244b783 -> ca3f3a492 MINOR: Document that Connect topics should use compaction Update documentation for Kafka Connect distributed’s config.storage.topic, offset.storage.topic, and status.storage.topic configuration values to indicate

kafka git commit: MINOR: Fixes javadoc of Windows, fixes typo in parameter name of KGroupedTable

2016-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 85c441023 -> 3a244b783 MINOR: Fixes javadoc of Windows, fixes typo in parameter name of KGroupedTable Author: Michael G. Noll Reviewers: Damian Guy, Ismael Juma, Guozhang Wang Closes #1823 from

kafka git commit: KAFKA-3129; Console producer issue when request-required-acks=0

2016-09-07 Thread ijuma
Repository: kafka Updated Branches: refs/heads/trunk 2586226a9 -> 85c441023 KAFKA-3129; Console producer issue when request-required-acks=0 change console producer default acks to 1, update acks docs. Also added the -1 config to the acks docs since that question comes up often. ijuma and

kafka git commit: KAFKA-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset

2016-09-07 Thread guozhang
Repository: kafka Updated Branches: refs/heads/trunk 16469d7f9 -> 2586226a9 KAFKA-4058: Failure in org.apache.kafka.streams.integration.ResetIntegrationTest.testReprocessingFromScratchAfterReset - use AdminTool to check for active consumer group Author: Matthias J. Sax