ewe...@apache.org |
kafka git commit: MINOR: bug fixes to ducktape services |
Fri, 01 Jul, 04:16 |
ewe...@apache.org |
kafka git commit: MINOR: bug fixes to ducktape services |
Fri, 01 Jul, 04:16 |
ewe...@apache.org |
kafka git commit: MINOR: fix Bash shebang on vagrant/ scripts |
Fri, 01 Jul, 18:48 |
ewe...@apache.org |
kafka git commit: KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) subscriptions |
Mon, 04 Jul, 21:09 |
ewe...@apache.org |
kafka git commit: KAFKA-3854: Fix issues with new consumer's subsequent regex (pattern) subscriptions |
Mon, 04 Jul, 22:42 |
ewe...@apache.org |
kafka git commit: KAFKA-3920: Add Schema source connector to Kafka Connect |
Fri, 08 Jul, 17:57 |
ewe...@apache.org |
kafka git commit: KAFKA-3782: Fix transient failure in connect distributed bounce test |
Fri, 22 Jul, 03:09 |
ewe...@apache.org |
kafka git commit: KAFKA-3782: Fix transient failure in connect distributed bounce test |
Fri, 22 Jul, 03:09 |
ewe...@apache.org |
kafka git commit: MINOR: Update to Gradle 2.14.1 |
Fri, 22 Jul, 04:32 |
ewe...@apache.org |
kafka git commit: MINOR: Small enhancement to Deserializer Javadoc |
Mon, 25 Jul, 18:03 |
ewe...@apache.org |
kafka git commit: MINOR: Small enhancement to Deserializer Javadoc |
Mon, 25 Jul, 18:03 |
ewe...@apache.org |
kafka git commit: KAFKA-3500: Handle null keys and values in KafkaOffsetBackingStore. |
Mon, 25 Jul, 21:25 |
ewe...@apache.org |
[kafka] Git Push Summary |
Mon, 25 Jul, 21:25 |
ewe...@apache.org |
kafka git commit: KAFKA-3851: Automate release notes and include links to upgrade notes for release and most recent docs to forward users of older releases to newest docs. |
Wed, 27 Jul, 05:33 |
ewe...@apache.org |
[kafka] Git Push Summary |
Wed, 27 Jul, 05:34 |
ewe...@apache.org |
kafka git commit: KAFKA-3852: Clarify how to handle message format upgrade without killing performance |
Thu, 28 Jul, 20:48 |
ewe...@apache.org |
kafka git commit: KAFKA-3852: Clarify how to handle message format upgrade without killing performance |
Thu, 28 Jul, 20:48 |
guozh...@apache.org |
kafka git commit: KAFKA-3902: Optimize KTable.filter in Streams DSL to avoid forwarding if both old and new values are null |
Fri, 01 Jul, 23:47 |
guozh...@apache.org |
kafka git commit: KAFKA-3902: Optimize KTable.filter in Streams DSL to avoid forwarding if both old and new values are null |
Fri, 01 Jul, 23:47 |
guozh...@apache.org |
kafka git commit: MINOR: Fix few documentation errors in streams quickstart |
Tue, 05 Jul, 02:56 |
guozh...@apache.org |
kafka git commit: resolve conflicts |
Tue, 05 Jul, 02:58 |
guozh...@apache.org |
kafka git commit: HOTFIX: Auto-repartitioning for merge() and code simplifications |
Tue, 05 Jul, 16:16 |
guozh...@apache.org |
kafka git commit: MINOR: Fix generics in KStream.groupBy(...) |
Tue, 05 Jul, 16:30 |
guozh...@apache.org |
kafka git commit: MINOR: fix generics in Windows.segments and Windows.until |
Tue, 05 Jul, 18:38 |
guozh...@apache.org |
kafka git commit: MINOR: fix generics in Windows.segments and Windows.until |
Tue, 05 Jul, 18:38 |
guozh...@apache.org |
kafka git commit: KAFKA-3794: added stream / table names as prefix to print / writeAsText |
Wed, 06 Jul, 17:46 |
guozh...@apache.org |
kafka git commit: KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers |
Wed, 06 Jul, 19:27 |
guozh...@apache.org |
kafka git commit: KAFKA-3836: KStreamReduce and KTableReduce should not pass nulls to Deserializers |
Wed, 06 Jul, 19:27 |
guozh...@apache.org |
kafka git commit: KAFKA-3926: Fix transient test failure in RegexSourceIntegrationTest |
Wed, 06 Jul, 19:32 |
guozh...@apache.org |
kafka git commit: KAFKA-3887: KAFKA-3817 follow-up to avoid forwarding value if it is null in KTableRepartition |
Fri, 08 Jul, 15:36 |
guozh...@apache.org |
kafka git commit: KAFKA-3887: KAFKA-3817 follow-up to avoid forwarding value if it is null in KTableRepartition |
Fri, 08 Jul, 15:36 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3887 Follow-up: add unit test for null checking in KTable aggregates |
Mon, 11 Jul, 20:57 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3887 Follow-up: add unit test for null checking in KTable aggregates |
Mon, 11 Jul, 20:57 |
guozh...@apache.org |
kafka git commit: KAFKA-3931: Fix transient failures in pattern subscription tests |
Tue, 12 Jul, 18:31 |
guozh...@apache.org |
kafka git commit: KAFKA-3931: Fix transient failures in pattern subscription tests |
Tue, 12 Jul, 18:31 |
guozh...@apache.org |
kafka git commit: MINOR: Check null in SmokeTestDriver to avoid NPE |
Tue, 12 Jul, 19:15 |
guozh...@apache.org |
kafka git commit: MINOR: Check null in SmokeTestDriver to avoid NPE |
Tue, 12 Jul, 19:15 |
guozh...@apache.org |
kafka git commit: KAFKA-3941: Delay eviction listener in InMemoryKeyValueLoggedStore after restoration |
Thu, 14 Jul, 01:11 |
guozh...@apache.org |
kafka git commit: KAFKA-3941: Delay eviction listener in InMemoryKeyValueLoggedStore after restoration |
Thu, 14 Jul, 01:12 |
guozh...@apache.org |
kafka git commit: KAFKA-3952: Consumer rebalance verifier never succeed due to type mismatch |
Fri, 15 Jul, 17:08 |
guozh...@apache.org |
kafka git commit: KAFKA-3952: Consumer rebalance verifier never succeed due to type mismatch |
Fri, 15 Jul, 17:09 |
guozh...@apache.org |
kafka git commit: KAFKA-3952: Consumer rebalance verifier never succeed due to type mismatch |
Fri, 15 Jul, 17:09 |
guozh...@apache.org |
kafka git commit: resolve conflicts |
Fri, 15 Jul, 17:11 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3870: Expose state store names in DSL |
Mon, 18 Jul, 19:12 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3870: Expose state store names in DSL |
Mon, 18 Jul, 19:12 |
guozh...@apache.org |
kafka git commit: MINOR: Added simple streams benchmark to system tests |
Mon, 18 Jul, 19:17 |
guozh...@apache.org |
kafka git commit: KAFKA-3855: Guard race conditions in TopologyBuilder |
Tue, 19 Jul, 15:44 |
guozh...@apache.org |
kafka git commit: resolve conflicts |
Tue, 19 Jul, 15:52 |
guozh...@apache.org |
kafka git commit: KAFKA-3922: add constructor to AbstractStream class |
Tue, 19 Jul, 17:56 |
guozh...@apache.org |
kafka git commit: KAFKA-3922: add constructor to AbstractStream class |
Tue, 19 Jul, 17:56 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3912: Query local state stores |
Tue, 19 Jul, 21:02 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3912: Query local state stores |
Tue, 19 Jul, 21:02 |
guozh...@apache.org |
kafka git commit: MINOR: Remove slf4j-log4j from kafka-streams compile dependencies |
Tue, 19 Jul, 22:45 |
guozh...@apache.org |
kafka git commit: MINOR: Remove slf4j-log4j from kafka-streams compile dependencies |
Tue, 19 Jul, 22:45 |
guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3812: fix state store directory locking in Kafka Streams |
Tue, 19 Jul, 23:00 |
guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3812: fix state store directory locking in Kafka Streams |
Tue, 19 Jul, 23:00 |
guozh...@apache.org |
kafka git commit: HOTFIX: fix compilation error due to merge of KAFKA-3812 |
Tue, 19 Jul, 23:54 |
guozh...@apache.org |
[1/2] kafka git commit: Cherry-pick KAFKA-3941: Delay eviction listener in InMemoryKeyValueLoggedStore after restoration |
Wed, 20 Jul, 00:47 |
guozh...@apache.org |
[2/2] kafka git commit: Merge branch '0.10.0' of https://git-wip-us.apache.org/repos/asf/kafka into 0.10.0 |
Wed, 20 Jul, 00:47 |
guozh...@apache.org |
kafka git commit: KAFKA-3915; Don't convert messages from v0 to v1 during log compaction |
Wed, 20 Jul, 19:49 |
guozh...@apache.org |
kafka git commit: resolve conflicts |
Wed, 20 Jul, 19:59 |
guozh...@apache.org |
kafka git commit: KAFKA-3740: Enable configuration of RocksDBStores |
Thu, 21 Jul, 18:04 |
guozh...@apache.org |
kafka git commit: KAFKA-3858: Add functions to print stream topologies |
Thu, 21 Jul, 20:11 |
guozh...@apache.org |
kafka git commit: KAFKA-3911: KTable source materialization |
Thu, 21 Jul, 21:45 |
guozh...@apache.org |
kafka git commit: MINOR: Upgrade RocksDB to 4.8.0 |
Thu, 21 Jul, 23:11 |
guozh...@apache.org |
kafka git commit: MINOR: Upgrade RocksDB to 4.8.0 |
Thu, 21 Jul, 23:11 |
guozh...@apache.org |
kafka git commit: KAFKA-3185: Allow users to cleanup internal Kafka Streams data |
Wed, 27 Jul, 21:11 |
guozh...@apache.org |
kafka git commit: KAFKA-3185: [Streams] Added Kafka Streams Application Reset Tool |
Wed, 27 Jul, 22:55 |
gwens...@apache.org |
kafka git commit: KAFKA-2941: Clarify docs for key and value Converters |
Mon, 11 Jul, 04:23 |
gwens...@apache.org |
kafka git commit: MINOR: Remove unused parameter in `checkIfPartitionReassignmentSucceeded` and clean-ups |
Wed, 20 Jul, 02:04 |
gwens...@apache.org |
kafka git commit: KAFKA-3500: Handle null keys and values in KafkaOffsetBackingStore. |
Wed, 27 Jul, 02:43 |
gwens...@apache.org |
kafka git commit: KAFKA-3500: Handle null keys and values in KafkaOffsetBackingStore. |
Wed, 27 Jul, 02:43 |
gwens...@apache.org |
kafka git commit: KAFKA-3946: Protocol guide should say that Produce request acks can o… |
Fri, 29 Jul, 22:54 |
ij...@apache.org |
kafka git commit: MINOR: remove "auto.commit.interval.ms" from "Manual Offset Control" example |
Sat, 02 Jul, 01:08 |
ij...@apache.org |
kafka git commit: MINOR: Fix consumer constructor doc string |
Sat, 02 Jul, 01:11 |
ij...@apache.org |
kafka git commit: MINOR: Typo fix in docs ops |
Sat, 02 Jul, 01:20 |
ij...@apache.org |
kafka git commit: MINOR: Warning instead of error if TGT cannot be renewed beyond the next expiry date |
Sat, 02 Jul, 01:36 |
ij...@apache.org |
kafka git commit: KAFKA-3802; log mtimes reset on broker restart / shutdown |
Wed, 06 Jul, 15:13 |
ij...@apache.org |
kafka git commit: KAFKA-3802; log mtimes reset on broker restart / shutdown |
Wed, 06 Jul, 15:13 |
ij...@apache.org |
kafka git commit: KAFKA-3844; Sort configuration items in log |
Sat, 09 Jul, 01:04 |
ij...@apache.org |
kafka git commit: MINOR: Update design.html |
Sat, 09 Jul, 01:07 |
ij...@apache.org |
kafka git commit: MINOR: Typo fix in comments |
Sat, 09 Jul, 01:09 |
ij...@apache.org |
kafka git commit: KAFKA-3849; Add explanation on why polling every second in MirrorMaker is required |
Sat, 09 Jul, 01:51 |
ij...@apache.org |
kafka git commit: KAFKA-3725; Update documentation with regards to XFS |
Mon, 11 Jul, 08:01 |
ij...@apache.org |
kafka git commit: KAFKA-3725; Update documentation with regards to XFS |
Mon, 11 Jul, 08:01 |
ij...@apache.org |
kafka git commit: KAFKA-3942; Change IntegrationTestUtils.purgeLocalStreamsState to use java.io.tmpdir |
Mon, 11 Jul, 08:50 |
ij...@apache.org |
kafka-site git commit: Update 0.10.0 docs from Kafka's 0.10.0 branch |
Mon, 11 Jul, 11:24 |
ij...@apache.org |
kafka git commit: KAFKA-3562; Handle topic deletion during a send |
Mon, 11 Jul, 16:31 |
ij...@apache.org |
kafka git commit: KAFKA-3905: Handling null/empty topics and collections, patterns when subscription with list of topics or with patterns, and with assignments. |
Thu, 14 Jul, 09:50 |
ij...@apache.org |
kafka git commit: MINOR: Doc of 'retries' config should mention max.in.flight.requests.per.connection to avoid confusion |
Tue, 19 Jul, 09:10 |
ij...@apache.org |
kafka git commit: MINOR: Doc of 'retries' config should mention max.in.flight.requests.per.connection to avoid confusion |
Tue, 19 Jul, 09:11 |
ij...@apache.org |
kafka git commit: MINOR: Fix typo in Operations section |
Tue, 19 Jul, 09:20 |
ij...@apache.org |
kafka git commit: MINOR: Fix typo in Operations section |
Tue, 19 Jul, 09:20 |
ij...@apache.org |
kafka git commit: KAFKA-3915; Don't convert messages from v0 to v1 during log compaction The conversion is unsafe as the converted message size may be greater than the message size limit. Updated `LogCleanerIntegrationTest` to test the max message size c [Forced Update!] |
Wed, 20 Jul, 20:19 |
ij...@apache.org |
kafka git commit: MINOR: MetadataCache brokerId is not set on first run with generated broker id |
Wed, 20 Jul, 23:49 |
ij...@apache.org |
kafka git commit: MINOR: Improve PartitionState logging and remove duplication of code |
Thu, 21 Jul, 00:00 |
ij...@apache.org |
kafka git commit: MINOR: Improve PartitionState logging and remove duplication of code |
Thu, 21 Jul, 00:00 |
ij...@apache.org |
kafka git commit: HOTFIX: Adding init file so streams benchmark is autodiscovered |
Thu, 21 Jul, 23:19 |
ij...@apache.org |
kafka git commit: MINOR: Increase default `waitTime` in `waitUntilTrue` to 15 seconds |
Fri, 22 Jul, 16:58 |
ij...@apache.org |
kafka git commit: KAFKA-3983; Add additional information to Acceptor debug message |
Fri, 22 Jul, 17:10 |