| ewe...@apache.org |
kafka git commit: KAFKA-2910: Close Zookeeper clients in unit tests |
Fri, 01 Apr, 17:52 |
| ewe...@apache.org |
kafka git commit: KAFKA-2910: Close Zookeeper clients in unit tests |
Fri, 01 Apr, 17:52 |
| ewe...@apache.org |
kafka git commit: KAFKA-3486: fix autocommit when partitions assigned manually |
Sun, 03 Apr, 06:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-3486: fix autocommit when partitions assigned manually |
Sun, 03 Apr, 06:02 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix small typo in design section |
Mon, 04 Apr, 01:15 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix small typo in design section |
Mon, 04 Apr, 01:15 |
| ewe...@apache.org |
kafka git commit: MINOR: Clean up of SourceTaskOffsetCommiter |
Mon, 04 Apr, 02:05 |
| ewe...@apache.org |
kafka git commit: MINOR: Clean up of SourceTaskOffsetCommiter |
Mon, 04 Apr, 02:05 |
| ewe...@apache.org |
[1/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:04 |
| ewe...@apache.org |
[2/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:04 |
| ewe...@apache.org |
[3/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:04 |
| ewe...@apache.org |
[4/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:04 |
| ewe...@apache.org |
[1/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:05 |
| ewe...@apache.org |
[2/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:05 |
| ewe...@apache.org |
[3/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:05 |
| ewe...@apache.org |
[4/4] kafka git commit: KAFKA-3483: Restructure ducktape tests to simplify running subsets of tests |
Mon, 04 Apr, 03:05 |
| ewe...@apache.org |
kafka git commit: KAFKA-3384: Conform to POSIX kill usage |
Tue, 05 Apr, 05:07 |
| ewe...@apache.org |
kafka git commit: KAFKA-3508: Fix transient SimpleACLAuthorizerTest failures |
Tue, 05 Apr, 22:18 |
| ewe...@apache.org |
kafka git commit: KAFKA-3488; Avoid failing of unsent requests in consumer where possible |
Thu, 07 Apr, 22:49 |
| ewe...@apache.org |
kafka git commit: MINOR: ensure original use of prop_file in verifiable producer |
Fri, 08 Apr, 01:17 |
| ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata |
Fri, 08 Apr, 16:00 |
| ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3505: Fix punctuate generated record metadata |
Fri, 08 Apr, 16:00 |
| ewe...@apache.org |
kafka git commit: MINOR: improve logging of consumer system tests |
Fri, 08 Apr, 17:04 |
| ewe...@apache.org |
kafka git commit: KAFKA-3528: handle wakeups while rebalancing more gracefully |
Fri, 08 Apr, 19:55 |
| ewe...@apache.org |
kafka git commit: KAFKA-3521: validate null keys in Streams DSL implementations |
Fri, 08 Apr, 20:30 |
| ewe...@apache.org |
kafka git commit: KAFKA-3490; Multiple version support for ducktape performance tests |
Wed, 13 Apr, 20:51 |
| ewe...@apache.org |
kafka git commit: KAFKA-3549: Close consumers instantiated in consumer tests |
Fri, 15 Apr, 05:02 |
| ewe...@apache.org |
kafka git commit: KAFKA-3526: Return string instead of object in ConfigKeyInfo and ConfigValueInfo |
Fri, 15 Apr, 22:51 |
| ewe...@apache.org |
kafka git commit: KAFKA-3506: Kafka Connect restart APIs |
Mon, 18 Apr, 17:51 |
| ewe...@apache.org |
kafka git commit: KAFKA-3529: Fix transient failure in testCommitAsync |
Mon, 18 Apr, 19:49 |
| ewe...@apache.org |
kafka git commit: KAFKA-3563: Maintain MessageAndMetadata constructor compatibility |
Mon, 18 Apr, 21:10 |
| ewe...@apache.org |
kafka git commit: KAFKA-3558; Add compression_type parameter to benchmarks in benchmark_test.py |
Mon, 18 Apr, 21:23 |
| ewe...@apache.org |
kafka git commit: KAFKA-3421: Update docs with new connector features |
Tue, 19 Apr, 18:06 |
| ewe...@apache.org |
[1/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API |
Wed, 20 Apr, 21:10 |
| ewe...@apache.org |
[2/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API |
Wed, 20 Apr, 21:10 |
| ewe...@apache.org |
[3/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API |
Wed, 20 Apr, 21:10 |
| ewe...@apache.org |
[4/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API |
Wed, 20 Apr, 21:10 |
| ewe...@apache.org |
[5/5] kafka git commit: KAFKA-2370: kafka connect pause/resume API |
Wed, 20 Apr, 21:10 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix comment in DistributedHerder |
Thu, 21 Apr, 00:50 |
| ewe...@apache.org |
kafka git commit: KAFKA-3606: Traverse CLASSPATH during herder start |
Fri, 22 Apr, 00:59 |
| ewe...@apache.org |
kafka git commit: KAFKA-3611: Remove warnings when using reflections |
Thu, 28 Apr, 18:59 |
| ewe...@apache.org |
kafka git commit: KAFKA-3382: Add system test for ReplicationVerificationTool |
Thu, 28 Apr, 22:49 |
| ewe...@apache.org |
kafka git commit: KAFKA-2693: Ducktape tests for SASL/PLAIN and multiple mechanisms |
Fri, 29 Apr, 16:41 |
| ewe...@apache.org |
kafka git commit: KAFKA-3418: add javadoc section describing consumer failure detection |
Fri, 29 Apr, 17:26 |
| ewe...@apache.org |
kafka git commit: KAFKA-3615: Exclude test jars in kafka-run-class.sh |
Fri, 29 Apr, 17:32 |
| ewe...@apache.org |
kafka git commit: KAFKA-3578: Allow cross origin HTTP requests on all HTTP methods |
Fri, 29 Apr, 17:53 |
| ewe...@apache.org |
kafka git commit: KAFKA-3440: Update streams javadocs |
Fri, 29 Apr, 19:50 |
| ewe...@apache.org |
kafka git commit: KAFKA-3459: Returning zero task configurations from a connector does not properly clean up existing tasks |
Fri, 29 Apr, 21:49 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Fix equality semantics of KeyValue |
Fri, 29 Apr, 22:14 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Fix equality semantics of KeyValue |
Fri, 29 Apr, 22:15 |
| guozh...@apache.org |
kafka git commit: MINOR: small code optimizations in streams |
Sat, 02 Apr, 00:14 |
| guozh...@apache.org |
kafka git commit: KAFKA-3419: clarify difference between topic subscription and partition assignment |
Sun, 03 Apr, 20:44 |
| guozh...@apache.org |
kafka git commit: HOTFIX: set timestamp in SinkNode |
Mon, 04 Apr, 21:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-2998: log warnings when client is disconnected from bootstrap brokers |
Tue, 05 Apr, 04:29 |
| guozh...@apache.org |
kafka git commit: KAFKA-3510; OffsetIndex thread safety |
Tue, 05 Apr, 18:46 |
| guozh...@apache.org |
kafka git commit: KAFKA-3477: extended KStream/KTable API to specify custom partitioner for sinks |
Tue, 05 Apr, 22:56 |
| guozh...@apache.org |
kafka git commit: KAFKA-3497: Streams ProcessorContext should support forward() based on child name |
Thu, 07 Apr, 17:20 |
| guozh...@apache.org |
kafka git commit: KAFKA-3512: Added foreach operator |
Fri, 08 Apr, 16:17 |
| guozh...@apache.org |
kafka git commit: KAFKA-725: Return OffsetOutOfRange error from ReplicaManager when non-follower attempts reading an offset that's above high watermark. |
Fri, 08 Apr, 16:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-3338: Add print and writeAsText to KStream/KTable in Kafka Streams |
Mon, 11 Apr, 00:43 |
| guozh...@apache.org |
kafka git commit: HOTFIX: special handling first ever triggered punctuate |
Mon, 11 Apr, 06:09 |
| guozh...@apache.org |
kafka git commit: MINOR: fix incorrect exception message in KafkaProducer |
Mon, 11 Apr, 19:02 |
| guozh...@apache.org |
kafka git commit: KAFKA-3519: Refactor Transformer's transform / punctuate to return nullable values |
Mon, 11 Apr, 19:33 |
| guozh...@apache.org |
kafka git commit: MINOR: Add missing `@Override` to `KStreamImpl.through` |
Tue, 12 Apr, 18:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-3504; Log compaction for changelog partition |
Wed, 13 Apr, 00:38 |
| guozh...@apache.org |
kafka git commit: KAFKA-3470: treat commits as member heartbeats |
Thu, 14 Apr, 01:09 |
| guozh...@apache.org |
kafka git commit: KAFKA-3557; Update rocksdb to 4.4.1 and patch updates to snappy and slf4j |
Thu, 14 Apr, 17:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-3430: Allow users to set key in KTable.toStream and in KStream. |
Sun, 17 Apr, 03:18 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix typos in code comments |
Wed, 20 Apr, 00:41 |
| guozh...@apache.org |
kafka git commit: KAFKA-3117: handle metadata updates during consumer rebalance |
Thu, 21 Apr, 00:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-3337: Extract selector as a separate groupBy operator for KTable aggregations |
Thu, 21 Apr, 20:42 |
| guozh...@apache.org |
kafka git commit: KAFKA-3589: set inner serializer for ChangedSerde upon initialization |
Thu, 21 Apr, 21:51 |
| guozh...@apache.org |
kafka git commit: KAFKA-3594; After calling MemoryRecords.close() method, hasRoomFor() method should return false |
Thu, 21 Apr, 22:13 |
| guozh...@apache.org |
kafka git commit: MINOR: add unit test for KGroupedTable.count |
Mon, 25 Apr, 18:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-3619: File handles are leaked on .lock files of ProcessorStateManager |
Mon, 25 Apr, 20:45 |
| guozh...@apache.org |
kafka git commit: KAFKA-3499: prevent array typed keys in KeyValueStore |
Tue, 26 Apr, 14:32 |
| guozh...@apache.org |
kafka git commit: MINOR: Fix some copy-pasted Javadoc in StreamsConfig.java |
Tue, 26 Apr, 16:11 |
| guozh...@apache.org |
kafka git commit: KAFKA-3614: Consolidate duplicate code in KGroupedTableImpl |
Tue, 26 Apr, 16:59 |
| guozh...@apache.org |
kafka git commit: KAKFA-3599: Move WindowStoreUtils to package "internals" |
Tue, 26 Apr, 17:53 |
| guozh...@apache.org |
[1/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 |
Tue, 26 Apr, 18:39 |
| guozh...@apache.org |
[2/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 |
Tue, 26 Apr, 18:39 |
| guozh...@apache.org |
[3/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 |
Tue, 26 Apr, 18:39 |
| guozh...@apache.org |
[4/4] kafka git commit: KAFKA-3607: Close KStreamTestDriver upon completing; follow-up fixes to be tracked in KAFKA-3623 |
Tue, 26 Apr, 18:39 |
| guozh...@apache.org |
kafka git commit: KAFKA-3629; KStreamImpl.to(...) throws NPE when the value SerDe is null |
Wed, 27 Apr, 17:50 |
| guozh...@apache.org |
kafka git commit: KAFKA-3612: Added structure for integration tests |
Wed, 27 Apr, 23:55 |
| guozh...@apache.org |
kafka git commit: KAFKA-3613: Consolidate TumblingWindows and HoppingWindows into TimeWindows |
Fri, 29 Apr, 14:44 |
| guozh...@apache.org |
kafka git commit: KAFKA-3598: Improve JavaDoc of public API |
Fri, 29 Apr, 15:49 |
| gwens...@apache.org |
kafka git commit: MINOR: add null check for aggregate and reduce operators |
Fri, 01 Apr, 20:14 |
| gwens...@apache.org |
kafka git commit: MINOR: add null check for aggregate and reduce operators |
Fri, 01 Apr, 20:15 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix BNF output for protocol arrays conataining primitives in docs |
Fri, 01 Apr, 20:56 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix BNF output for protocol arrays conataining primitives in docs |
Fri, 01 Apr, 20:56 |
| gwens...@apache.org |
kafka git commit: MINOR: Fix BNF output for protocol arrays conataining primitives in docs |
Fri, 01 Apr, 20:56 |
| gwens...@apache.org |
kafka git commit: MINOR: Add check for empty topics iterator in ReplicaVerificationTool. |
Fri, 01 Apr, 21:12 |
| gwens...@apache.org |
kafka git commit: KAFKA-2844; Separate keytabs for sasl tests |
Fri, 01 Apr, 22:25 |
| gwens...@apache.org |
kafka git commit: KAFKA-2930: Update references to ZooKeeper in the docs. |
Fri, 01 Apr, 22:57 |
| gwens...@apache.org |
kafka git commit: KAFKA-3464: Add system tests for Connect with Kafka security enabled |
Tue, 05 Apr, 01:49 |
| gwens...@apache.org |
[01/21] kafka git commit: MINOR: Revert 0.10.0 branch to SNAPSHOT per change in release process |
Wed, 06 Apr, 00:09 |
| gwens...@apache.org |
[02/21] kafka git commit: Changing version to 0.10.0.0 |
Wed, 06 Apr, 00:09 |
| gwens...@apache.org |
[03/21] kafka git commit: KAFKA-3510; OffsetIndex thread safety |
Wed, 06 Apr, 00:09 |
| gwens...@apache.org |
[04/21] kafka git commit: KAFKA-2930: Update references to ZooKeeper in the docs. |
Wed, 06 Apr, 00:09 |