| guozh...@apache.org |
kafka git commit: MINOR: Fix Vagrant setup script for use on Fedora |
Fri, 02 Oct, 22:03 |
| guozh...@apache.org |
kafka git commit: MINOR: remove no longer needed CommitType |
Fri, 02 Oct, 22:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-2597: Add to .gitignore the Eclipse IDE directories |
Fri, 02 Oct, 22:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-2591: Fix StreamingMetrics |
Sat, 03 Oct, 03:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-2604; Remove `completeAll` and improve timeout passed to `Selector.poll` from `NetworkClient.poll` |
Mon, 05 Oct, 18:57 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Persistent store in ProcessorStateManagerTest |
Mon, 05 Oct, 20:54 |
| guozh...@apache.org |
kafka git commit: TRIVIAL: remove TODO in KafkaConsumer after KAFKA-2120 |
Mon, 05 Oct, 21:07 |
| guozh...@apache.org |
kafka git commit: KAFKA-2599: Fix Metadata.getClusterForCurrentTopics throws NPE |
Tue, 06 Oct, 20:35 |
| guozh...@apache.org |
kafka git commit: KAFKA-2573: Mirror maker system test hangs and eventually fails |
Tue, 06 Oct, 21:06 |
| guozh...@apache.org |
kafka git commit: KAFKA-2482: Allow sink tasks to get their current assignment, as well as pause and resume topic partitions. |
Tue, 06 Oct, 21:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-2474: Add caching of JSON schema conversions to JsonConverter |
Tue, 06 Oct, 22:27 |
| guozh...@apache.org |
kafka git commit: KAFKA-2476: Add Decimal, Date, and Timestamp logical types. |
Wed, 07 Oct, 04:58 |
| guozh...@apache.org |
kafka-site git commit: HOTFIX: update contributing.html for web docs |
Wed, 07 Oct, 18:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-2428: Add sanity check in KafkaConsumer for the timeouts |
Thu, 08 Oct, 01:26 |
| guozh...@apache.org |
kafka git commit: MINOR: typing ProcessorDef |
Fri, 09 Oct, 06:14 |
| guozh...@apache.org |
kafka git commit: KAFKA-2596: reject commits from unknown groups with positive generations |
Fri, 09 Oct, 06:35 |
| guozh...@apache.org |
kafka git commit: KAFKA-2622: Add Time logical type for Copycat. |
Fri, 09 Oct, 18:55 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2600: Align Kafka Streams' interfaces with Java 8 functional interfaces |
Fri, 09 Oct, 19:14 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2600: Align Kafka Streams' interfaces with Java 8 functional interfaces |
Fri, 09 Oct, 19:14 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix exception message in Copycat's Time logical type. |
Fri, 09 Oct, 20:04 |
| guozh...@apache.org |
kafka git commit: MINOR: putting back kstream stateful transform methods |
Fri, 09 Oct, 23:24 |
| guozh...@apache.org |
kafka git commit: KAFKA-2203: Getting Java8 to relax about javadoc and let our build pass |
Mon, 12 Oct, 20:31 |
| guozh...@apache.org |
kafka git commit: KAFKA-2581: Run some existing ducktape tests with SSL |
Tue, 13 Oct, 00:15 |
| guozh...@apache.org |
kafka git commit: MINOR: flush record collector after local state flush |
Tue, 13 Oct, 22:26 |
| guozh...@apache.org |
kafka git commit: KAFKA-2603: Add timeout arg to ConsoleConsumer for new consumer |
Wed, 14 Oct, 20:31 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2593: Key value stores can use specified serializers and deserializers |
Wed, 14 Oct, 20:54 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2593: Key value stores can use specified serializers and deserializers |
Wed, 14 Oct, 20:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-2654: optimize unnecessary poll(0) away in StreamTask |
Thu, 15 Oct, 18:02 |
| guozh...@apache.org |
kafka git commit: KAFKA-2295; Support dynamically loaded classes from context class loader |
Thu, 15 Oct, 18:06 |
| guozh...@apache.org |
kafka git commit: MINOR: set up temp directories properly in StreamTaskTest |
Thu, 15 Oct, 18:45 |
| guozh...@apache.org |
kafka git commit: KAFKA-2487: change kafka.examples.Consumer to use the new java consumer |
Fri, 16 Oct, 00:23 |
| guozh...@apache.org |
kafka git commit: KAFKA-2120: cleaning follow-up |
Fri, 16 Oct, 16:40 |
| guozh...@apache.org |
kafka git commit: KAFKA-2594: Add InMemoryLRUCacheStore as a preliminary method for bounding in-memory stores |
Fri, 16 Oct, 21:41 |
| guozh...@apache.org |
kafka git commit: KAFKA-2515: Handle oversized messages properly in new consumer |
Sat, 17 Oct, 00:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-2397: add leave group request to force coordinator trigger rebalance |
Sat, 17 Oct, 00:41 |
| guozh...@apache.org |
kafka git commit: KAFKA-2665: Add images to code github |
Sat, 17 Oct, 00:47 |
| guozh...@apache.org |
kafka git commit: MINOR: Fixed README examples on running specific tests. |
Mon, 19 Oct, 05:40 |
| guozh...@apache.org |
kafka git commit: KAFKA-2669; Fix LogCleaner.awaitCleaned for LogCleanerIntegrationTest |
Mon, 19 Oct, 21:45 |
| guozh...@apache.org |
kafka git commit: MINOR: Capture stderr in ConsumerPerformanceService. |
Tue, 20 Oct, 00:14 |
| guozh...@apache.org |
kafka git commit: HOTFIX: check logic of KAFKA-2515 should be on buffer.limit() |
Tue, 20 Oct, 02:28 |
| guozh...@apache.org |
kafka git commit: KAFKA-2459: Mark last committed timestamp to fix connection backoff |
Wed, 21 Oct, 16:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-2667: Fix transient error in KafkaBasedLogTest. |
Wed, 21 Oct, 18:15 |
| guozh...@apache.org |
kafka git commit: MINOR: Update to Gradle 2.8 |
Wed, 21 Oct, 18:33 |
| guozh...@apache.org |
[1/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[2/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[3/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[4/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[5/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[6/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[7/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
[8/8] kafka git commit: KAFKA-2464: client-side assignment for new consumer |
Wed, 21 Oct, 19:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-2678; partition level lag metrics can be negative |
Thu, 22 Oct, 16:21 |
| guozh...@apache.org |
kafka git commit: MINOR: Restore `SslConsumerTest` which was accidentally deleted in client-side assignment commit |
Thu, 22 Oct, 16:47 |
| guozh...@apache.org |
kafka git commit: KAFKA-2686: Reset needsPartitionAssignment in SubscriptionState.assign() |
Fri, 23 Oct, 04:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-2449: Update mirror maker docs |
Mon, 26 Oct, 17:12 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-2652: integrate new group protocol into partition grouping |
Mon, 26 Oct, 20:28 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-2652: integrate new group protocol into partition grouping |
Mon, 26 Oct, 20:28 |
| guozh...@apache.org |
kafka git commit: MINOR: follow-up to KAFKA-2464 for renaming/cleanup |
Tue, 27 Oct, 01:25 |
| guozh...@apache.org |
kafka git commit: KAFKA-2694: Reformat task id as group id and partition id |
Tue, 27 Oct, 03:09 |
| guozh...@apache.org |
kafka git commit: HOTFIX: group rebalance can throw illegal generation or rebalance in progress |
Tue, 27 Oct, 20:39 |
| guozh...@apache.org |
kafka git commit: HOTFIX: fix off-by-one stream offset commit |
Tue, 27 Oct, 20:44 |
| guozh...@apache.org |
kafka git commit: HOTFIX: call consumer.poll() even when no task is assigned |
Tue, 27 Oct, 20:52 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-1888: rolling upgrade test |
Tue, 27 Oct, 22:18 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-1888: rolling upgrade test |
Tue, 27 Oct, 22:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-2677: ensure consumer sees coordinator disconnects |
Tue, 27 Oct, 23:18 |
| guozh...@apache.org |
kafka git commit: HOTFIX: correct sourceNodes for kstream.through() |
Tue, 27 Oct, 23:21 |
| guozh...@apache.org |
kafka git commit: KAFKA-2683: ensure wakeup exceptions raised to user |
Wed, 28 Oct, 00:34 |
| guozh...@apache.org |
kafka git commit: MINOR: Expose ReplicaManager gauges |
Wed, 28 Oct, 00:50 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Rename WakeupException in MirrorMaker |
Wed, 28 Oct, 02:27 |
| guozh...@apache.org |
kafka git commit: MINOR: Clean-up MemoryRecords variables and APIs |
Wed, 28 Oct, 17:05 |
| guozh...@apache.org |
kafka git commit: KAFKA-2648: enforce non-empty group-ids in join-group request |
Wed, 28 Oct, 21:08 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix missing copyright in config file added in KAFKA-2640. |
Thu, 29 Oct, 03:39 |
| guozh...@apache.org |
kafka git commit: MINOR: Update system test MANIFEST.in |
Fri, 30 Oct, 15:51 |
| gwens...@apache.org |
[01/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:18 |
| gwens...@apache.org |
[02/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[03/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[04/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[05/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[06/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[07/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[08/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[09/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[10/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[11/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[12/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[13/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[14/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[15/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[16/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[17/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[18/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[19/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[20/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[21/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[22/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[23/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[24/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[25/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[26/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |
| gwens...@apache.org |
[27/51] [partial] kafka-site git commit: KAFKA-2425: Initial upload of Kafka documentation to git repository with intent to replace SVN |
Fri, 02 Oct, 19:19 |