commits@kafka.apache.org, 2016-04

You are viewing a plain text version of this content. The canonical link for it is here.

- kafka git commit: KAFKA-2910: Close Zookeeper clients in unit tests - posted by ew...@apache.org on 2016/04/01 19:52:45 UTC, 1 replies.
- kafka git commit: MINOR: add null check for aggregate and reduce operators - posted by gw...@apache.org on 2016/04/01 22:14:51 UTC, 1 replies.
- kafka git commit: MINOR: Fix BNF output for protocol arrays conataining primitives in docs - posted by gw...@apache.org on 2016/04/01 22:56:15 UTC, 2 replies.
- kafka git commit: MINOR: Add check for empty topics iterator in ReplicaVerificationTool. - posted by gw...@apache.org on 2016/04/01 23:12:53 UTC, 0 replies.
- kafka git commit: KAFKA-2844; Separate keytabs for sasl tests - posted by gw...@apache.org on 2016/04/02 00:25:49 UTC, 0 replies.
- kafka git commit: KAFKA-2930: Update references to ZooKeeper in the docs. - posted by gw...@apache.org on 2016/04/02 00:57:44 UTC, 0 replies.
- kafka git commit: MINOR: small code optimizations in streams - posted by gu...@apache.org on 2016/04/02 02:14:33 UTC, 0 replies.
- kafka git commit: KAFKA-3486: fix autocommit when partitions assigned manually - posted by ew...@apache.org on 2016/04/03 08:02:34 UTC, 1 replies.
- kafka git commit: KAFKA-3419: clarify difference between topic subscription and partition assignment - posted by gu...@apache.org on 2016/04/03 22:44:09 UTC, 0 replies.
- kafka git commit: KAFKA-3495; NetworkClient.blockingSendAndReceive` should rely on requestTimeout - posted by ju...@apache.org on 2016/04/04 01:34:50 UTC, 0 replies.
- kafka git commit: MINOR: Fix small typo in design section - posted by ew...@apache.org on 2016/04/04 03:15:16 UTC, 1 replies.
- kafka git commit: MINOR: Clean up of SourceTaskOffsetCommiter - posted by ew...@apache.org on 2016/04/04 04:05:06 UTC, 1 replies.
- [1/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by ew...@apache.org on 2016/04/04 05:04:51 UTC, 1 replies.
- [2/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by ew...@apache.org on 2016/04/04 05:04:52 UTC, 1 replies.
- [3/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by ew...@apache.org on 2016/04/04 05:04:53 UTC, 1 replies.
- [4/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by ew...@apache.org on 2016/04/04 05:04:54 UTC, 1 replies.
- kafka git commit: HOTFIX: set timestamp in SinkNode - posted by gu...@apache.org on 2016/04/04 23:57:21 UTC, 0 replies.
- kafka git commit: KAFKA-3464: Add system tests for Connect with Kafka security enabled - posted by gw...@apache.org on 2016/04/05 03:49:40 UTC, 0 replies.
- kafka git commit: KAFKA-2998: log warnings when client is disconnected from bootstrap brokers - posted by gu...@apache.org on 2016/04/05 06:29:06 UTC, 0 replies.
- kafka git commit: KAFKA-3384: Conform to POSIX kill usage - posted by ew...@apache.org on 2016/04/05 07:07:45 UTC, 0 replies.
- kafka git commit: KAFKA-3510; OffsetIndex thread safety - posted by gu...@apache.org on 2016/04/05 20:46:09 UTC, 0 replies.
- kafka git commit: KAFKA-3489; Update request metrics if a client closes a connection while the broker response is in flight - posted by ju...@apache.org on 2016/04/06 00:16:52 UTC, 0 replies.
- kafka git commit: KAFKA-3508: Fix transient SimpleACLAuthorizerTest failures - posted by ew...@apache.org on 2016/04/06 00:18:10 UTC, 0 replies.
- kafka git commit: KAFKA-3477: extended KStream/KTable API to specify custom partitioner for sinks - posted by gu...@apache.org on 2016/04/06 00:56:13 UTC, 0 replies.
- [01/21] kafka git commit: MINOR: Revert 0.10.0 branch to SNAPSHOT per change in release process - posted by gw...@apache.org on 2016/04/06 02:09:08 UTC, 0 replies.
- [02/21] kafka git commit: Changing version to 0.10.0.0 - posted by gw...@apache.org on 2016/04/06 02:09:09 UTC, 0 replies.
- [03/21] kafka git commit: KAFKA-3510; OffsetIndex thread safety - posted by gw...@apache.org on 2016/04/06 02:09:10 UTC, 0 replies.
- [04/21] kafka git commit: KAFKA-2930: Update references to ZooKeeper in the docs. - posted by gw...@apache.org on 2016/04/06 02:09:11 UTC, 0 replies.
- [05/21] kafka git commit: Changing version to 0.10.1.0-SNAPSHOT - posted by gw...@apache.org on 2016/04/06 02:09:12 UTC, 0 replies.
- [06/21] kafka git commit: MINOR: update new version in additional places - posted by gw...@apache.org on 2016/04/06 02:09:13 UTC, 0 replies.
- [07/21] kafka git commit: KAFKA-3445: Validate TASKS_MAX_CONFIG's lower bound - posted by gw...@apache.org on 2016/04/06 02:09:14 UTC, 0 replies.
- [08/21] kafka git commit: KAFKA-3407 - ErrorLoggingCallback trims helpful diagnostic information. - posted by gw...@apache.org on 2016/04/06 02:09:15 UTC, 0 replies.
- [09/21] kafka git commit: MINOR: Add check for empty topics iterator in ReplicaVerificationTool. - posted by gw...@apache.org on 2016/04/06 02:09:16 UTC, 0 replies.
- [10/21] kafka git commit: MINOR: small code optimizations in streams - posted by gw...@apache.org on 2016/04/06 02:09:17 UTC, 0 replies.
- [11/21] kafka git commit: KAFKA-2844; Separate keytabs for sasl tests - posted by gw...@apache.org on 2016/04/06 02:09:18 UTC, 0 replies.
- [12/21] kafka git commit: KAFKA-3419: clarify difference between topic subscription and partition assignment - posted by gw...@apache.org on 2016/04/06 02:09:19 UTC, 0 replies.
- [13/21] kafka git commit: KAFKA-3495; NetworkClient.blockingSendAndReceive` should rely on requestTimeout - posted by gw...@apache.org on 2016/04/06 02:09:20 UTC, 0 replies.
- [14/21] kafka git commit: HOTFIX: set timestamp in SinkNode - posted by gw...@apache.org on 2016/04/06 02:09:21 UTC, 0 replies.
- [15/21] kafka git commit: KAFKA-3464: Add system tests for Connect with Kafka security enabled - posted by gw...@apache.org on 2016/04/06 02:09:22 UTC, 0 replies.
- [16/21] kafka git commit: KAFKA-2998: log warnings when client is disconnected from bootstrap brokers - posted by gw...@apache.org on 2016/04/06 02:09:23 UTC, 0 replies.
- [17/21] kafka git commit: KAFKA-3489; Update request metrics if a client closes a connection while the broker response is in flight - posted by gw...@apache.org on 2016/04/06 02:09:24 UTC, 0 replies.
- [18/21] kafka git commit: KAFKA-3384: Conform to POSIX kill usage - posted by gw...@apache.org on 2016/04/06 02:09:25 UTC, 0 replies.
- [19/21] kafka git commit: KAFKA-3508: Fix transient SimpleACLAuthorizerTest failures - posted by gw...@apache.org on 2016/04/06 02:09:26 UTC, 0 replies.
- [20/21] kafka git commit: MINOR: update new version in additional places - posted by gw...@apache.org on 2016/04/06 02:09:27 UTC, 0 replies.
- [21/21] kafka git commit: KAFKA-3477: extended KStream/KTable API to specify custom partitioner for sinks - posted by gw...@apache.org on 2016/04/06 02:09:28 UTC, 0 replies.
- kafka git commit: KAFKA-3497: Streams ProcessorContext should support forward() based on child name - posted by gu...@apache.org on 2016/04/07 19:20:21 UTC, 0 replies.
- kafka git commit: KAFKA-3488; Avoid failing of unsent requests in consumer where possible - posted by ew...@apache.org on 2016/04/08 00:49:18 UTC, 0 replies.
- kafka git commit: MINOR: ensure original use of prop_file in verifiable producer - posted by ew...@apache.org on 2016/04/08 03:17:57 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata - posted by ew...@apache.org on 2016/04/08 18:00:04 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata - posted by ew...@apache.org on 2016/04/08 18:00:05 UTC, 0 replies.
- kafka git commit: KAFKA-3512: Added foreach operator - posted by gu...@apache.org on 2016/04/08 18:17:10 UTC, 0 replies.
- kafka git commit: KAFKA-725: Return OffsetOutOfRange error from ReplicaManager when non-follower attempts reading an offset that's above high watermark. - posted by gu...@apache.org on 2016/04/08 18:44:56 UTC, 0 replies.
- kafka git commit: MINOR: improve logging of consumer system tests - posted by ew...@apache.org on 2016/04/08 19:04:58 UTC, 0 replies.
- kafka git commit: KAFKA-3528: handle wakeups while rebalancing more gracefully - posted by ew...@apache.org on 2016/04/08 21:55:36 UTC, 0 replies.
- kafka git commit: KAFKA-3521: validate null keys in Streams DSL implementations - posted by ew...@apache.org on 2016/04/08 22:30:57 UTC, 0 replies.
- kafka git commit: KAFKA-3338: Add print and writeAsText to KStream/KTable in Kafka Streams - posted by gu...@apache.org on 2016/04/11 02:43:51 UTC, 0 replies.
- kafka git commit: HOTFIX: special handling first ever triggered punctuate - posted by gu...@apache.org on 2016/04/11 08:09:48 UTC, 0 replies.
- kafka git commit: MINOR: Make VerifiableProducer in system tests lookup security configuration dynamically instead of at construction. - posted by gw...@apache.org on 2016/04/11 19:37:11 UTC, 0 replies.
- kafka git commit: MINOR: fix incorrect exception message in KafkaProducer - posted by gu...@apache.org on 2016/04/11 21:02:52 UTC, 0 replies.
- kafka git commit: KAFKA-3519: Refactor Transformer's transform / punctuate to return nullable values - posted by gu...@apache.org on 2016/04/11 21:33:50 UTC, 0 replies.
- [01/50] [abbrv] kafka git commit: KAFKA-3388; Fix expiration of batches sitting in the accumulator - posted by gw...@apache.org on 2016/04/12 01:09:17 UTC, 0 replies.
- [02/50] [abbrv] kafka git commit: MINOR: Fix typo and tweak wording in `RecordAccumulator` comments - posted by gw...@apache.org on 2016/04/12 01:09:18 UTC, 0 replies.
- [03/50] [abbrv] kafka git commit: MINOR: Remove a couple of redundant `CoreUtils.rm` methods - posted by gw...@apache.org on 2016/04/12 01:09:19 UTC, 0 replies.
- [04/50] [abbrv] kafka git commit: HOTFIX: RocksDBStore must clear dirty flags after flush - posted by gw...@apache.org on 2016/04/12 01:09:20 UTC, 0 replies.
- [05/50] [abbrv] kafka git commit: KAFKA-3425: add missing upgrade notes - posted by gw...@apache.org on 2016/04/12 01:09:21 UTC, 0 replies.
- [06/50] [abbrv] kafka git commit: MINOR: Advance system test ducktape dependency from 0.3.10 to 0.4.0 - posted by gw...@apache.org on 2016/04/12 01:09:22 UTC, 0 replies.
- [07/50] [abbrv] kafka git commit: MINOR: a simple benchmark for Streams - posted by gw...@apache.org on 2016/04/12 01:09:23 UTC, 0 replies.
- [08/50] [abbrv] kafka git commit: KAFKA-3475; Introduce our own `MiniKdc` - posted by gw...@apache.org on 2016/04/12 01:09:24 UTC, 0 replies.
- [09/50] [abbrv] kafka git commit: KAFKA-3381: Add system test for SimpleConsumerShell - posted by gw...@apache.org on 2016/04/12 01:09:25 UTC, 0 replies.
- [10/50] [abbrv] kafka git commit: KAFKA-3451: Add basic HTML coverage report generation to gradle - posted by gw...@apache.org on 2016/04/12 01:09:26 UTC, 0 replies.
- [11/50] [abbrv] kafka git commit: KAFKA-2910: Close Zookeeper clients in unit tests - posted by gw...@apache.org on 2016/04/12 01:09:27 UTC, 0 replies.
- [12/50] [abbrv] kafka git commit: MINOR: add null check for aggregate and reduce operators - posted by gw...@apache.org on 2016/04/12 01:09:28 UTC, 0 replies.
- [13/50] [abbrv] kafka git commit: MINOR: Fix BNF output for protocol arrays conataining primitives in docs - posted by gw...@apache.org on 2016/04/12 01:09:29 UTC, 0 replies.
- [14/50] [abbrv] kafka git commit: MINOR: Add check for empty topics iterator in ReplicaVerificationTool. - posted by gw...@apache.org on 2016/04/12 01:09:30 UTC, 0 replies.
- [15/50] [abbrv] kafka git commit: KAFKA-2844; Separate keytabs for sasl tests - posted by gw...@apache.org on 2016/04/12 01:09:31 UTC, 0 replies.
- [16/50] [abbrv] kafka git commit: KAFKA-2930: Update references to ZooKeeper in the docs. - posted by gw...@apache.org on 2016/04/12 01:09:32 UTC, 0 replies.
- [17/50] [abbrv] kafka git commit: MINOR: small code optimizations in streams - posted by gw...@apache.org on 2016/04/12 01:09:33 UTC, 0 replies.
- [18/50] [abbrv] kafka git commit: KAFKA-3486: fix autocommit when partitions assigned manually - posted by gw...@apache.org on 2016/04/12 01:09:34 UTC, 0 replies.
- [19/50] [abbrv] kafka git commit: KAFKA-3419: clarify difference between topic subscription and partition assignment - posted by gw...@apache.org on 2016/04/12 01:09:35 UTC, 0 replies.
- [20/50] [abbrv] kafka git commit: KAFKA-3495; NetworkClient.blockingSendAndReceive` should rely on requestTimeout - posted by gw...@apache.org on 2016/04/12 01:09:36 UTC, 0 replies.
- [21/50] [abbrv] kafka git commit: MINOR: Fix small typo in design section - posted by gw...@apache.org on 2016/04/12 01:09:37 UTC, 0 replies.
- [22/50] [abbrv] kafka git commit: MINOR: Clean up of SourceTaskOffsetCommiter - posted by gw...@apache.org on 2016/04/12 01:09:38 UTC, 0 replies.
- [23/50] [abbrv] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by gw...@apache.org on 2016/04/12 01:09:39 UTC, 0 replies.
- [24/50] [abbrv] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by gw...@apache.org on 2016/04/12 01:09:40 UTC, 0 replies.
- [25/50] [abbrv] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by gw...@apache.org on 2016/04/12 01:09:41 UTC, 0 replies.
- [26/50] [abbrv] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests - posted by gw...@apache.org on 2016/04/12 01:09:42 UTC, 0 replies.
- [27/50] [abbrv] kafka git commit: HOTFIX: set timestamp in SinkNode - posted by gw...@apache.org on 2016/04/12 01:09:43 UTC, 0 replies.
- [28/50] [abbrv] kafka git commit: KAFKA-3464: Add system tests for Connect with Kafka security enabled - posted by gw...@apache.org on 2016/04/12 01:09:44 UTC, 0 replies.
- [29/50] [abbrv] kafka git commit: KAFKA-2998: log warnings when client is disconnected from bootstrap brokers - posted by gw...@apache.org on 2016/04/12 01:09:45 UTC, 0 replies.
- [30/50] [abbrv] kafka git commit: KAFKA-3384: Conform to POSIX kill usage - posted by gw...@apache.org on 2016/04/12 01:09:46 UTC, 0 replies.
- [31/50] [abbrv] kafka git commit: KAFKA-3510; OffsetIndex thread safety - posted by gw...@apache.org on 2016/04/12 01:09:47 UTC, 0 replies.
- [32/50] [abbrv] kafka git commit: KAFKA-3489; Update request metrics if a client closes a connection while the broker response is in flight - posted by gw...@apache.org on 2016/04/12 01:09:48 UTC, 0 replies.
- [33/50] [abbrv] kafka git commit: KAFKA-3508: Fix transient SimpleACLAuthorizerTest failures - posted by gw...@apache.org on 2016/04/12 01:09:49 UTC, 0 replies.
- [34/50] [abbrv] kafka git commit: KAFKA-3477: extended KStream/KTable API to specify custom partitioner for sinks - posted by gw...@apache.org on 2016/04/12 01:09:50 UTC, 0 replies.
- [35/50] [abbrv] kafka git commit: KAFKA-3497: Streams ProcessorContext should support forward() based on child name - posted by gw...@apache.org on 2016/04/12 01:09:51 UTC, 0 replies.
- [36/50] [abbrv] kafka git commit: KAFKA-3488; Avoid failing of unsent requests in consumer where possible - posted by gw...@apache.org on 2016/04/12 01:09:52 UTC, 0 replies.
- [37/50] [abbrv] kafka git commit: MINOR: ensure original use of prop_file in verifiable producer - posted by gw...@apache.org on 2016/04/12 01:09:53 UTC, 0 replies.
- [38/50] [abbrv] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata - posted by gw...@apache.org on 2016/04/12 01:09:54 UTC, 0 replies.
- [39/50] [abbrv] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata - posted by gw...@apache.org on 2016/04/12 01:09:55 UTC, 0 replies.
- [40/50] [abbrv] kafka git commit: KAFKA-3512: Added foreach operator - posted by gw...@apache.org on 2016/04/12 01:09:56 UTC, 0 replies.
- [41/50] [abbrv] kafka git commit: KAFKA-725: Return OffsetOutOfRange error from ReplicaManager when non-follower attempts reading an offset that's above high watermark. - posted by gw...@apache.org on 2016/04/12 01:09:57 UTC, 0 replies.
- [42/50] [abbrv] kafka git commit: MINOR: improve logging of consumer system tests - posted by gw...@apache.org on 2016/04/12 01:09:58 UTC, 0 replies.
- [43/50] [abbrv] kafka git commit: KAFKA-3528: handle wakeups while rebalancing more gracefully - posted by gw...@apache.org on 2016/04/12 01:09:59 UTC, 0 replies.
- [44/50] [abbrv] kafka git commit: KAFKA-3521: validate null keys in Streams DSL implementations - posted by gw...@apache.org on 2016/04/12 01:10:00 UTC, 0 replies.
- [45/50] [abbrv] kafka git commit: KAFKA-3338: Add print and writeAsText to KStream/KTable in Kafka Streams - posted by gw...@apache.org on 2016/04/12 01:10:01 UTC, 0 replies.
- [46/50] [abbrv] kafka git commit: HOTFIX: special handling first ever triggered punctuate - posted by gw...@apache.org on 2016/04/12 01:10:02 UTC, 0 replies.
- [47/50] [abbrv] kafka git commit: MINOR: Make VerifiableProducer in system tests lookup security configuration dynamically instead of at construction. - posted by gw...@apache.org on 2016/04/12 01:10:03 UTC, 0 replies.
- [48/50] [abbrv] kafka git commit: MINOR: fix incorrect exception message in KafkaProducer - posted by gw...@apache.org on 2016/04/12 01:10:04 UTC, 0 replies.
- [49/50] [abbrv] kafka git commit: KAFKA-3519: Refactor Transformer's transform / punctuate to return nullable values - posted by gw...@apache.org on 2016/04/12 01:10:05 UTC, 0 replies.
- [50/50] [abbrv] kafka git commit: Merge branch 'trunk' into 0.10.0 - posted by gw...@apache.org on 2016/04/12 01:10:06 UTC, 1 replies.
- kafka git commit: Minor: Correcting version to 0.10.0.0-SNAPSHOT again following merge with trunk - posted by gw...@apache.org on 2016/04/12 01:36:24 UTC, 0 replies.
- kafka git commit: MINOR: Add missing `@Override` to `KStreamImpl.through` - posted by gu...@apache.org on 2016/04/12 20:34:49 UTC, 0 replies.
- kafka git commit: KAFKA-3439; Added exceptions thrown - posted by gw...@apache.org on 2016/04/12 22:01:02 UTC, 0 replies.
- kafka git commit: MINOR: Remove unused hadoop version - posted by gw...@apache.org on 2016/04/12 22:47:06 UTC, 0 replies.
- kafka git commit: KAFKA-3461: Fix typos in Kafka web documentations. - posted by gw...@apache.org on 2016/04/12 22:48:23 UTC, 0 replies.
- kafka git commit: KAFKA-3504; Log compaction for changelog partition - posted by gu...@apache.org on 2016/04/13 02:38:24 UTC, 0 replies.
- kafka git commit: KAFKA-3490; Multiple version support for ducktape performance tests - posted by ew...@apache.org on 2016/04/13 22:51:12 UTC, 0 replies.
- kafka git commit: KAFKA-3470: treat commits as member heartbeats - posted by gu...@apache.org on 2016/04/14 03:09:12 UTC, 0 replies.
- kafka git commit: KAFKA-3557; Update rocksdb to 4.4.1 and patch updates to snappy and slf4j - posted by gu...@apache.org on 2016/04/14 19:44:08 UTC, 0 replies.
- kafka git commit: KAFKA-3549: Close consumers instantiated in consumer tests - posted by ew...@apache.org on 2016/04/15 07:02:36 UTC, 0 replies.
- kafka git commit: KAFKA-3526: Return string instead of object in ConfigKeyInfo and ConfigValueInfo - posted by ew...@apache.org on 2016/04/16 00:51:49 UTC, 0 replies.
- kafka git commit: KAFKA-3430: Allow users to set key in KTable.toStream and in KStream. - posted by gu...@apache.org on 2016/04/17 05:18:30 UTC, 0 replies.
- kafka git commit: KAFKA-3506: Kafka Connect restart APIs - posted by ew...@apache.org on 2016/04/18 19:51:15 UTC, 0 replies.
- kafka git commit: KAFKA-3529: Fix transient failure in testCommitAsync - posted by ew...@apache.org on 2016/04/18 21:49:48 UTC, 0 replies.
- kafka git commit: KAFKA-3563: Maintain MessageAndMetadata constructor compatibility - posted by ew...@apache.org on 2016/04/18 23:10:45 UTC, 0 replies.
- kafka git commit: KAFKA-3558; Add compression_type parameter to benchmarks in benchmark_test.py - posted by ew...@apache.org on 2016/04/18 23:23:57 UTC, 0 replies.
- kafka git commit: KAFKA-3582; Remove references to Copcyat from Kafka Connect property files - posted by ju...@apache.org on 2016/04/19 03:49:30 UTC, 0 replies.
- kafka git commit: KAFKA-3421: Update docs with new connector features - posted by ew...@apache.org on 2016/04/19 20:06:46 UTC, 0 replies.
- kafka git commit: MINOR: Fix typos in code comments - posted by gu...@apache.org on 2016/04/20 02:41:05 UTC, 0 replies.
- kafka git commit: MINOR: Remove RollingBounceTest since its functionality is covered by the ReplicationTest system test - posted by gw...@apache.org on 2016/04/20 19:16:51 UTC, 0 replies.
- [1/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API - posted by ew...@apache.org on 2016/04/20 23:10:20 UTC, 0 replies.
- [2/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API - posted by ew...@apache.org on 2016/04/20 23:10:21 UTC, 0 replies.
- [3/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API - posted by ew...@apache.org on 2016/04/20 23:10:22 UTC, 0 replies.
- [4/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API - posted by ew...@apache.org on 2016/04/20 23:10:23 UTC, 0 replies.
- [5/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API - posted by ew...@apache.org on 2016/04/20 23:10:24 UTC, 0 replies.
- kafka git commit: KAFKA-3117: handle metadata updates during consumer rebalance - posted by gu...@apache.org on 2016/04/21 02:08:03 UTC, 0 replies.
- kafka git commit: MINOR: Fix comment in DistributedHerder - posted by ew...@apache.org on 2016/04/21 02:50:56 UTC, 0 replies.
- kafka git commit: KAFKA-3548: Use root locale for case transformation of constant strings - posted by gw...@apache.org on 2016/04/21 03:54:37 UTC, 0 replies.
- kafka git commit: KAFKA-3337: Extract selector as a separate groupBy operator for KTable aggregations - posted by gu...@apache.org on 2016/04/21 22:42:21 UTC, 0 replies.
- kafka git commit: KAFKA-3589: set inner serializer for ChangedSerde upon initialization - posted by gu...@apache.org on 2016/04/21 23:51:24 UTC, 0 replies.
- kafka git commit: KAFKA-3594; After calling MemoryRecords.close() method, hasRoomFor() method should return false - posted by gu...@apache.org on 2016/04/22 00:13:29 UTC, 0 replies.
- kafka git commit: KAFKA-3606: Traverse CLASSPATH during herder start - posted by ew...@apache.org on 2016/04/22 02:59:28 UTC, 0 replies.
- kafka git commit: KAFKA-3605: Return error if connector config includes mismatching connector name. - posted by gw...@apache.org on 2016/04/22 16:09:20 UTC, 0 replies.
- kafka git commit: MINOR: add unit test for KGroupedTable.count - posted by gu...@apache.org on 2016/04/25 20:18:31 UTC, 0 replies.
- kafka git commit: KAFKA-3619: File handles are leaked on .lock files of ProcessorStateManager - posted by gu...@apache.org on 2016/04/25 22:45:54 UTC, 0 replies.
- kafka git commit: KAFKA-3270; Added some Happy Path Tests for the Reassign Partitions Command - posted by ij...@apache.org on 2016/04/26 15:31:21 UTC, 0 replies.
- kafka git commit: KAFKA-3602; Rename RecordAccumulator dequeFor() and fix usage - posted by ij...@apache.org on 2016/04/26 15:37:33 UTC, 0 replies.
- kafka-site git commit: Add Ismael to committers page - posted by ij...@apache.org on 2016/04/26 16:05:16 UTC, 0 replies.
- kafka git commit: KAFKA-3499: prevent array typed keys in KeyValueStore - posted by gu...@apache.org on 2016/04/26 16:32:26 UTC, 0 replies.
- kafka git commit: MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java - posted by gu...@apache.org on 2016/04/26 18:11:43 UTC, 0 replies.
- kafka git commit: KAFKA-3614: Consolidate duplicate code in KGroupedTableImpl - posted by gu...@apache.org on 2016/04/26 18:59:41 UTC, 0 replies.
- kafka git commit: KAKFA-3599: Move WindowStoreUtils to package "internals" - posted by gu...@apache.org on 2016/04/26 19:53:56 UTC, 0 replies.
- kafka git commit: MINOR: Typo fixes in ReplicaFetchMaxBytesDoc - posted by ij...@apache.org on 2016/04/26 20:25:34 UTC, 0 replies.
- [1/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gu...@apache.org on 2016/04/26 20:39:51 UTC, 0 replies.
- [2/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gu...@apache.org on 2016/04/26 20:39:52 UTC, 0 replies.
- [3/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gu...@apache.org on 2016/04/26 20:39:53 UTC, 0 replies.
- [4/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gu...@apache.org on 2016/04/26 20:39:54 UTC, 0 replies.
- kafka git commit: MINOR: Fix zk path in KafkaHealthCheck comment - posted by ij...@apache.org on 2016/04/26 20:46:29 UTC, 0 replies.
- kafka git commit: MINOR: Changed port of bootstrap server to default - posted by ij...@apache.org on 2016/04/26 20:52:44 UTC, 0 replies.
- kafka git commit: KAFKA-3427; Broker should return correct version of FetchResponse on exception - posted by ij...@apache.org on 2016/04/26 20:59:38 UTC, 0 replies.
- kafka git commit: MINOR: Upgrade to Gradle 2.13 - posted by gw...@apache.org on 2016/04/27 00:14:37 UTC, 0 replies.
- [1/3] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by ij...@apache.org on 2016/04/27 01:57:12 UTC, 0 replies.
- [2/3] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by ij...@apache.org on 2016/04/27 01:57:13 UTC, 0 replies.
- [3/3] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by ij...@apache.org on 2016/04/27 01:57:14 UTC, 0 replies.
- [1/2] kafka git commit: KAFKA-3306: Change metadata response to include required additional fi… - posted by gw...@apache.org on 2016/04/27 02:03:25 UTC, 0 replies.
- [2/2] kafka git commit: KAFKA-3306: Change metadata response to include required additional fi… - posted by gw...@apache.org on 2016/04/27 02:03:26 UTC, 0 replies.
- kafka git commit: KAFKA-3406; Update CommonClientConfigs.RETRY_BACKOFF_MS_DOC doc string - posted by ij...@apache.org on 2016/04/27 09:03:43 UTC, 0 replies.
- kafka git commit: KAFKA-3580; Improve error logging in ReplicaFetchThread - posted by ij...@apache.org on 2016/04/27 15:53:33 UTC, 0 replies.
- kafka git commit: KAFKA-3629; KStreamImpl.to(...) throws NPE when the value SerDe is null - posted by gu...@apache.org on 2016/04/27 19:50:24 UTC, 0 replies.
- kafka git commit: KAFKA-3307; Add ApiVersions Request/Response and server side handling. - posted by gw...@apache.org on 2016/04/27 20:28:37 UTC, 0 replies.
- kafka git commit: KAFKA-3612: Added structure for integration tests - posted by gu...@apache.org on 2016/04/28 01:55:54 UTC, 0 replies.
- kafka git commit: KAFKA-3631; Fix Struct.toString for nullable arrayOf - posted by ij...@apache.org on 2016/04/28 02:29:20 UTC, 0 replies.
- kafka git commit: KAFKA-3621; Add tests for ApiVersionRequest/Response - posted by ij...@apache.org on 2016/04/28 05:58:51 UTC, 0 replies.
- kafka git commit: KAFKA-3611: Remove warnings when using reflections - posted by ew...@apache.org on 2016/04/28 20:59:14 UTC, 0 replies.
- kafka git commit: KAFKA-3617; Unit tests for SASL authenticator - posted by ij...@apache.org on 2016/04/28 22:39:36 UTC, 0 replies.
- kafka git commit: KAFKA-3636; Change default max session timeout to 5 minutes - posted by ij...@apache.org on 2016/04/28 23:24:02 UTC, 0 replies.
- kafka git commit: MINOR: Avoid compiler warnings when registering metrics in KafkaServer - posted by ij...@apache.org on 2016/04/29 00:40:36 UTC, 0 replies.
- kafka git commit: KAFKA-3382: Add system test for ReplicationVerificationTool - posted by ew...@apache.org on 2016/04/29 00:49:12 UTC, 0 replies.
- kafka git commit: KAFKA-3613: Consolidate TumblingWindows and HoppingWindows into TimeWindows - posted by gu...@apache.org on 2016/04/29 16:44:10 UTC, 0 replies.
- kafka git commit: KAFKA-3598: Improve JavaDoc of public API - posted by gu...@apache.org on 2016/04/29 17:49:19 UTC, 0 replies.
- kafka git commit: KAFKA-2693: Ducktape tests for SASL/PLAIN and multiple mechanisms - posted by ew...@apache.org on 2016/04/29 18:41:24 UTC, 0 replies.
- kafka git commit: KAFKA-3418: add javadoc section describing consumer failure detection - posted by ew...@apache.org on 2016/04/29 19:26:27 UTC, 0 replies.
- kafka git commit: KAFKA-3615: Exclude test jars in kafka-run-class.sh - posted by ew...@apache.org on 2016/04/29 19:32:48 UTC, 0 replies.
- kafka git commit: KAFKA-3597; Query ConsoleConsumer and VerifiableProducer if they shutdown cleanly - posted by gw...@apache.org on 2016/04/29 19:51:32 UTC, 0 replies.
- kafka git commit: KAFKA-3578: Allow cross origin HTTP requests on all HTTP methods - posted by ew...@apache.org on 2016/04/29 19:53:02 UTC, 0 replies.
- kafka git commit: KAFKA-3618; Handle ApiVersionsRequest before SASL authentication - posted by gw...@apache.org on 2016/04/29 20:15:24 UTC, 0 replies.
- kafka git commit: KAFKA-3440: Update streams javadocs - posted by ew...@apache.org on 2016/04/29 21:50:18 UTC, 0 replies.
- kafka git commit: KAFKA-3641; Fix RecordMetadata constructor backward compatibility - posted by gw...@apache.org on 2016/04/29 23:48:33 UTC, 0 replies.
- kafka git commit: KAFKA-3459: Returning zero task configurations from a connector does not properly clean up existing tasks - posted by ew...@apache.org on 2016/04/29 23:49:37 UTC, 0 replies.
- [01/50] [abbrv] kafka git commit: KAFKA-3337: Extract selector as a separate groupBy operator for KTable aggregations - posted by gw...@apache.org on 2016/04/30 00:05:15 UTC, 0 replies.
- [02/50] [abbrv] kafka git commit: KAFKA-3589: set inner serializer for ChangedSerde upon initialization - posted by gw...@apache.org on 2016/04/30 00:05:16 UTC, 0 replies.
- [03/50] [abbrv] kafka git commit: KAFKA-3594; After calling MemoryRecords.close() method, hasRoomFor() method should return false - posted by gw...@apache.org on 2016/04/30 00:05:17 UTC, 0 replies.
- [04/50] [abbrv] kafka git commit: KAFKA-3606: Traverse CLASSPATH during herder start - posted by gw...@apache.org on 2016/04/30 00:05:18 UTC, 0 replies.
- [05/50] [abbrv] kafka git commit: KAFKA-3605: Return error if connector config includes mismatching connector name. - posted by gw...@apache.org on 2016/04/30 00:05:19 UTC, 0 replies.
- [06/50] [abbrv] kafka git commit: MINOR: add unit test for KGroupedTable.count - posted by gw...@apache.org on 2016/04/30 00:05:20 UTC, 0 replies.
- [07/50] [abbrv] kafka git commit: KAFKA-3619: File handles are leaked on .lock files of ProcessorStateManager - posted by gw...@apache.org on 2016/04/30 00:05:21 UTC, 0 replies.
- [08/50] [abbrv] kafka git commit: KAFKA-3270; Added some Happy Path Tests for the Reassign Partitions Command - posted by gw...@apache.org on 2016/04/30 00:05:22 UTC, 0 replies.
- [09/50] [abbrv] kafka git commit: KAFKA-3602; Rename RecordAccumulator dequeFor() and fix usage - posted by gw...@apache.org on 2016/04/30 00:05:23 UTC, 0 replies.
- [10/50] [abbrv] kafka git commit: KAFKA-3499: prevent array typed keys in KeyValueStore - posted by gw...@apache.org on 2016/04/30 00:05:24 UTC, 0 replies.
- [11/50] [abbrv] kafka git commit: MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java - posted by gw...@apache.org on 2016/04/30 00:05:25 UTC, 0 replies.
- [12/50] [abbrv] kafka git commit: KAFKA-3614: Consolidate duplicate code in KGroupedTableImpl - posted by gw...@apache.org on 2016/04/30 00:05:26 UTC, 0 replies.
- [13/50] [abbrv] kafka git commit: KAKFA-3599: Move WindowStoreUtils to package "internals" - posted by gw...@apache.org on 2016/04/30 00:05:27 UTC, 0 replies.
- [14/50] [abbrv] kafka git commit: MINOR: Typo fixes in ReplicaFetchMaxBytesDoc - posted by gw...@apache.org on 2016/04/30 00:05:28 UTC, 0 replies.
- [15/50] [abbrv] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gw...@apache.org on 2016/04/30 00:05:29 UTC, 0 replies.
- [16/50] [abbrv] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gw...@apache.org on 2016/04/30 00:05:30 UTC, 0 replies.
- [17/50] [abbrv] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gw...@apache.org on 2016/04/30 00:05:31 UTC, 0 replies.
- [18/50] [abbrv] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 - posted by gw...@apache.org on 2016/04/30 00:05:32 UTC, 0 replies.
- [19/50] [abbrv] kafka git commit: MINOR: Fix zk path in KafkaHealthCheck comment - posted by gw...@apache.org on 2016/04/30 00:05:33 UTC, 0 replies.
- [20/50] [abbrv] kafka git commit: MINOR: Changed port of bootstrap server to default - posted by gw...@apache.org on 2016/04/30 00:05:34 UTC, 0 replies.
- [21/50] [abbrv] kafka git commit: MINOR: Upgrade to Gradle 2.13 - posted by gw...@apache.org on 2016/04/30 00:05:35 UTC, 0 replies.
- [22/50] [abbrv] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by gw...@apache.org on 2016/04/30 00:05:36 UTC, 0 replies.
- [23/50] [abbrv] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by gw...@apache.org on 2016/04/30 00:05:37 UTC, 0 replies.
- [24/50] [abbrv] kafka git commit: KAFKA-3149; Extend SASL implementation to support more mechanisms - posted by gw...@apache.org on 2016/04/30 00:05:38 UTC, 0 replies.
- [25/50] [abbrv] kafka git commit: KAFKA-3306: Change metadata response to include required additional fi… - posted by gw...@apache.org on 2016/04/30 00:05:39 UTC, 0 replies.
- [26/50] [abbrv] kafka git commit: KAFKA-3306: Change metadata response to include required additional fi… - posted by gw...@apache.org on 2016/04/30 00:05:40 UTC, 0 replies.
- [27/50] [abbrv] kafka git commit: KAFKA-3406; Update CommonClientConfigs.RETRY_BACKOFF_MS_DOC doc string - posted by gw...@apache.org on 2016/04/30 00:05:41 UTC, 0 replies.
- [28/50] [abbrv] kafka git commit: KAFKA-3580; Improve error logging in ReplicaFetchThread - posted by gw...@apache.org on 2016/04/30 00:05:42 UTC, 0 replies.
- [29/50] [abbrv] kafka git commit: KAFKA-3629; KStreamImpl.to(...) throws NPE when the value SerDe is null - posted by gw...@apache.org on 2016/04/30 00:05:43 UTC, 0 replies.
- [30/50] [abbrv] kafka git commit: KAFKA-3307; Add ApiVersions Request/Response and server side handling. - posted by gw...@apache.org on 2016/04/30 00:05:44 UTC, 0 replies.
- [31/50] [abbrv] kafka git commit: KAFKA-3612: Added structure for integration tests - posted by gw...@apache.org on 2016/04/30 00:05:45 UTC, 0 replies.
- [32/50] [abbrv] kafka git commit: KAFKA-3631; Fix Struct.toString for nullable arrayOf - posted by gw...@apache.org on 2016/04/30 00:05:46 UTC, 0 replies.
- [33/50] [abbrv] kafka git commit: KAFKA-3621; Add tests for ApiVersionRequest/Response - posted by gw...@apache.org on 2016/04/30 00:05:47 UTC, 0 replies.
- [34/50] [abbrv] kafka git commit: KAFKA-3611: Remove warnings when using reflections - posted by gw...@apache.org on 2016/04/30 00:05:48 UTC, 0 replies.
- [35/50] [abbrv] kafka git commit: KAFKA-3617; Unit tests for SASL authenticator - posted by gw...@apache.org on 2016/04/30 00:05:49 UTC, 0 replies.
- [36/50] [abbrv] kafka git commit: KAFKA-3636; Change default max session timeout to 5 minutes - posted by gw...@apache.org on 2016/04/30 00:05:50 UTC, 0 replies.
- [37/50] [abbrv] kafka git commit: MINOR: Avoid compiler warnings when registering metrics in KafkaServer - posted by gw...@apache.org on 2016/04/30 00:05:51 UTC, 0 replies.
- [38/50] [abbrv] kafka git commit: KAFKA-3382: Add system test for ReplicationVerificationTool - posted by gw...@apache.org on 2016/04/30 00:05:52 UTC, 0 replies.
- [39/50] [abbrv] kafka git commit: KAFKA-3613: Consolidate TumblingWindows and HoppingWindows into TimeWindows - posted by gw...@apache.org on 2016/04/30 00:05:53 UTC, 0 replies.
- [40/50] [abbrv] kafka git commit: KAFKA-3598: Improve JavaDoc of public API - posted by gw...@apache.org on 2016/04/30 00:05:54 UTC, 0 replies.
- [41/50] [abbrv] kafka git commit: KAFKA-2693: Ducktape tests for SASL/PLAIN and multiple mechanisms - posted by gw...@apache.org on 2016/04/30 00:05:55 UTC, 0 replies.
- [42/50] [abbrv] kafka git commit: KAFKA-3418: add javadoc section describing consumer failure detection - posted by gw...@apache.org on 2016/04/30 00:05:56 UTC, 0 replies.
- [43/50] [abbrv] kafka git commit: KAFKA-3615: Exclude test jars in kafka-run-class.sh - posted by gw...@apache.org on 2016/04/30 00:05:57 UTC, 0 replies.
- [44/50] [abbrv] kafka git commit: KAFKA-3597; Query ConsoleConsumer and VerifiableProducer if they shutdown cleanly - posted by gw...@apache.org on 2016/04/30 00:05:58 UTC, 0 replies.
- [45/50] [abbrv] kafka git commit: KAFKA-3578: Allow cross origin HTTP requests on all HTTP methods - posted by gw...@apache.org on 2016/04/30 00:05:59 UTC, 0 replies.
- [46/50] [abbrv] kafka git commit: KAFKA-3618; Handle ApiVersionsRequest before SASL authentication - posted by gw...@apache.org on 2016/04/30 00:06:00 UTC, 0 replies.
- [47/50] [abbrv] kafka git commit: KAFKA-3440: Update streams javadocs - posted by gw...@apache.org on 2016/04/30 00:06:01 UTC, 0 replies.
- [48/50] [abbrv] kafka git commit: KAFKA-3641; Fix RecordMetadata constructor backward compatibility - posted by gw...@apache.org on 2016/04/30 00:06:02 UTC, 0 replies.
- [49/50] [abbrv] kafka git commit: KAFKA-3459: Returning zero task configurations from a connector does not properly clean up existing tasks - posted by gw...@apache.org on 2016/04/30 00:06:03 UTC, 0 replies.
- kafka git commit: HOTFIX: Fix equality semantics of KeyValue - posted by ew...@apache.org on 2016/04/30 00:14:50 UTC, 1 replies.
- [kafka] Git Push Summary - posted by gw...@apache.org on 2016/04/30 00:30:45 UTC, 0 replies.
- kafka git commit: MINOR: change initial value of Min stat to Double.MAX_VALUE (not MIN) - posted by gw...@apache.org on 2016/04/30 00:49:52 UTC, 0 replies.
- [1/2] kafka-site git commit: Docs for 0.10.0.0, release candidate 3 - posted by gw...@apache.org on 2016/04/30 01:50:26 UTC, 0 replies.
- [2/2] kafka-site git commit: Merge branch 'asf-site' of https://git-wip-us.apache.org/repos/asf/kafka-site into asf-site - posted by gw...@apache.org on 2016/04/30 01:50:27 UTC, 0 replies.
- kafka git commit: KAFKA-3644; Use Boolean protocol type for StopReplicaRequest delete_p… - posted by gw...@apache.org on 2016/04/30 02:27:07 UTC, 0 replies.