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
---
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 co
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 Process
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
t
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 miguno/trunk-windowed-javadocs
Project: ht
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
v