4072 Commits (9ef2b3ce8e4553504e52385a6370bf641fc6ea1e)
 

Author SHA1 Message Date
Damian Guy 17bdd4831c MINOR: remove unused eosEnabled field from ProcessorStateManager 7 years ago
Michael G. Noll 7429f49780 MINOR: reduce() javadocs: clarify position of arguments 7 years ago
Matthias J. Sax 0dfeb31a11 KAFKA-5485; Streams should not suspend tasks twice 7 years ago
Jason Gustafson c4193cd1ad MINOR: Rename baseTimestamp to firstTimestamp to clarify usage 7 years ago
Dong Lin a16475eb33 KAFKA-5544; The LastStableOffsetLag metric should be removed when partition is deleted 7 years ago
Colin P. Mccabe 5536b1237f KAFKA-5484: Refactor kafkatest docker support 7 years ago
Ismael Juma 27fdd46dcd MINOR: Improve TransactionIndex.sanityCheck() message 7 years ago
Rajini Sivaram dc95456f1d KAFKA-5402; Avoid creating quota related metrics if quotas not enabled 7 years ago
Ismael Juma a05a00e503 MINOR: Implement `toString` in some Validator instances 7 years ago
Jason Gustafson cb0325d484 KAFKA-5490; Cleaner should retain empty batch if needed to preserve producer last sequence 7 years ago
Apurva Mehta f05c70b069 MINOR: Enable the TransactionsBounceTest 7 years ago
Michal Borowiecki efb060c57f KAFKA-5233; KIP-138: Change punctuate semantics 7 years ago
Ismael Juma a293e1dc0c MINOR: Adjust checkstyle suppression paths to work on Windows 7 years ago
Matthias J. Sax 1d28e25748 MINOR: remove unnecessary null check 7 years ago
Jason Gustafson 031da889bc MINOR: Fix race condition in KafkaConsumer close 7 years ago
Apurva Mehta f1cc8008e5 KAFKA-5032; Update the docs for message size configs across the board 7 years ago
Ewen Cheslack-Postava e45c767d53 MINOR: Make JmxMixin wait for the monitored process to be listening on the JMX port before launching JmxTool 7 years ago
Matthias J. Sax 2265834803 KAFKA-5362: Add Streams EOS system test with repartitioning topic 8 years ago
Ismael Juma a5c47db138 KAFKA-5506; Fix NPE in OffsetFetchRequest.toString and logging improvements 8 years ago
Eno Thereska ee5eac715d KAFKA-5487; upgrade and downgrade streams app system test 8 years ago
Guozhang Wang d5e463b9de KAFKA-4829: Improve log4j on Streams thread / task-level 8 years ago
Ismael Juma d65844b527 MINOR: SaslChannelBuilder should be idempotent 8 years ago
Eno Thereska b490368735 HOTFIX: Don't check metadata unless you are creating topic 8 years ago
ppatierno 9ada0f8169 MINOR: Fixed way how logging methods are used for having a consistent one 8 years ago
Jeyhun Karimov 701e318ee1 KAFKA-4653; Improve test coverage of RocksDBStore 8 years ago
Jeyhun Karimov 26eea1d71e KAFKA-4656; Improve test coverage of CompositeReadOnlyKeyValueStore 8 years ago
Damian Guy 2420491f41 KAFKA-4913; prevent creation of window stores with less than 2 segments 8 years ago
Matthias J. Sax ac53979647 MINOR: update AWS test setup guide 8 years ago
Matthias J. Sax b62cccd078 MINOR: improve test README 8 years ago
Matthias J. Sax 4baca9172d HOTFIX: reduce log verbosity on commit 8 years ago
Onur Karaman 6d2fbfc911 KAFKA-5502; read current brokers from zookeeper upon processing broker change 8 years ago
Ewen Cheslack-Postava cd11fd7874 KAFKA-5498: ConfigDef derived from another ConfigDef did not correctly compute parentless configs 8 years ago
Ismael Juma 5d9563d95f MINOR: Switch ZK client logging to INFO 8 years ago
Jason Gustafson fc58ac594f KAFKA-5490; Skip empty record batches in the consumer 8 years ago
Jeyhun Karimov 1744a9b4c2 KAFKA-4658; Improve test coverage InMemoryKeyValueLoggedStore 8 years ago
Jeyhun Karimov adfaa11611 KAFKA-4655; Improve test coverage of CompositeReadOnlySessionStore 8 years ago
Kevin Sweeney 785d8e20ca MINOR: Provide link to ZooKeeper within Quickstart 8 years ago
Tom Bentley a6799f4e14 KAFKA-4059; API Design section under Implementation is out of date 8 years ago
Ismael Juma a4794b11b2 KAFKA-5486: org.apache.kafka logging should go to server.log 8 years ago
Jeyhun Karimov cb5e1f0a40 KAFKA-4785; Records from internal repartitioning topics should always use RecordMetadataTimestampExtractor 8 years ago
Guozhang Wang 7f4feda959 MINOR: Turn off caching in demos for more understandable outputs 8 years ago
Jeyhun Karimov 4e8797f54e KAFKA-4659; Improve test coverage of CachingKeyValueStore 8 years ago
Matthias J. Sax 914e42a282 KAFKA-5474: Streams StandbyTask should no checkpoint on commit if EOS is enabled 8 years ago
Apurva Mehta bc47e9d6ca KAFKA-5491; Enable transactions in ProducerPerformance Tool 8 years ago
Ewen Cheslack-Postava 96587f4b1f KAFKA-5475: Connector config validation should include fields for defined transformation aliases 8 years ago
Jason Gustafson e6e2631743 MINOR: Detail message/batch size implications for conversion between old and new formats 8 years ago
Guozhang Wang f848e2cd68 Revert "MINOR: make flush no-op as we don't need to call flush on commit." 8 years ago
Apurva Mehta 254add9534 KAFKA-5477; Lower retry backoff for first AddPartitions in transaction 8 years ago
Eno Thereska 55a90938a1 MINOR: add Yahoo benchmark to nightly runs 8 years ago
Matthias J. Sax cae5977ed0 MINOR: explain producer naming within Streams 8 years ago