| ewe...@apache.org |
kafka git commit: KAFKA-4261: Provide debug option in vagrant-up.sh |
Tue, 03 Jan, 22:47 |
| ewe...@apache.org |
kafka git commit: KAFKA-4575: ensure topic created before starting sink for ConnectDistributedTest.test_pause_resume_sink |
Thu, 05 Jan, 23:22 |
| ewe...@apache.org |
kafka git commit: KAFKA-4465: Create docker image and scripts for running tests locally |
Mon, 09 Jan, 00:12 |
| ewe...@apache.org |
kafka git commit: KAFKA-4402: make the KafkaProducer true round robin per topic |
Mon, 09 Jan, 04:08 |
| ewe...@apache.org |
kafka git commit: TRIVIAL: Fix spelling of log message |
Tue, 10 Jan, 06:12 |
| ewe...@apache.org |
kafka git commit: MINOR: Fix small error in javadoc for persistent Stores |
Tue, 10 Jan, 06:53 |
| ewe...@apache.org |
kafka git commit: HOTFIX: Convert exception introduced in KAFKA-3637 to warning since clearly it is happening. |
Tue, 10 Jan, 08:01 |
| ewe...@apache.org |
kafka git commit: MINOR: Add Replication Quotas Test Rig |
Tue, 10 Jan, 08:43 |
| ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3209: KIP-66: single message transforms |
Fri, 13 Jan, 00:15 |
| ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3209: KIP-66: single message transforms |
Fri, 13 Jan, 00:15 |
| ewe...@apache.org |
kafka git commit: MINOR: avoid closing over both pre & post-transform record in WorkerSourceTask |
Fri, 13 Jan, 01:09 |
| ewe...@apache.org |
kafka git commit: MINOR: Cluster file generator should produce valid json |
Fri, 13 Jan, 18:22 |
| ewe...@apache.org |
kafka git commit: KAFKA-4381: Add per partition lag metrics to the consumer |
Fri, 13 Jan, 19:38 |
| ewe...@apache.org |
kafka git commit: Bump version to 0.10.3.0-SNAPSHOT |
Mon, 16 Jan, 19:39 |
| ewe...@apache.org |
[kafka] Git Push Summary |
Mon, 16 Jan, 19:40 |
| ewe...@apache.org |
kafka-site git commit: new europe meetup links |
Fri, 20 Jan, 22:09 |
| ewe...@apache.org |
kafka-site git commit: new design for powered by page |
Fri, 20 Jan, 22:27 |
| ewe...@apache.org |
[1/2] kafka git commit: KAFKA-3209: KIP-66: more single message transforms |
Sat, 21 Jan, 00:16 |
| ewe...@apache.org |
[2/2] kafka git commit: KAFKA-3209: KIP-66: more single message transforms |
Sat, 21 Jan, 00:16 |
| ewe...@apache.org |
kafka git commit: KAFKA-4673: Fix thread-safety of Python VerifiableConsumer class |
Tue, 24 Jan, 21:19 |
| ewe...@apache.org |
kafka git commit: KAFKA-4673: Fix thread-safety of Python VerifiableConsumer class |
Tue, 24 Jan, 21:19 |
| ewe...@apache.org |
kafka git commit: KAFKA-4673: Fix thread-safety of Python VerifiableConsumer class |
Tue, 24 Jan, 21:19 |
| ewe...@apache.org |
kafka-site git commit: Add Grant to committers page |
Tue, 24 Jan, 23:26 |
| ewe...@apache.org |
kafka git commit: MINOR: Update consumer group describe output in the documentation |
Wed, 25 Jan, 00:24 |
| ewe...@apache.org |
kafka git commit: MINOR: Update consumer group describe output in the documentation |
Wed, 25 Jan, 00:24 |
| ewe...@apache.org |
kafka-site git commit: fix typos on powered by page |
Wed, 25 Jan, 00:59 |
| ewe...@apache.org |
kafka git commit: MINOR: Escape '<' and '>' symbols in quickstart streams code snippet |
Thu, 26 Jan, 23:04 |
| ewe...@apache.org |
kafka git commit: MINOR: Escape '<' and '>' symbols in quickstart streams code snippet |
Thu, 26 Jan, 23:05 |
| ewe...@apache.org |
kafka git commit: MINOR: Update copyright year in the NOTICE file. |
Fri, 27 Jan, 22:49 |
| ewe...@apache.org |
kafka git commit: MINOR: Update copyright year in the NOTICE file. |
Fri, 27 Jan, 22:49 |
| ewe...@apache.org |
kafka git commit: MINOR: Update copyright year in the NOTICE file. |
Fri, 27 Jan, 22:49 |
| ewe...@apache.org |
kafka git commit: KAFKA-4679: Remove unstable markers from Connect APIs |
Sat, 28 Jan, 03:58 |
| ewe...@apache.org |
kafka git commit: KAFKA-4679: Remove unstable markers from Connect APIs |
Sat, 28 Jan, 03:59 |
| guozh...@apache.org |
kafka git commit: KAFKA-4561; Ordering of operations in StreamThread.shutdownTasksAndState may void at-least-once guarantees |
Tue, 03 Jan, 16:34 |
| guozh...@apache.org |
kafka git commit: KAFKA-2434: Remove identical topic subscription constraint for roundrobin strategy in old consumer API |
Tue, 03 Jan, 16:57 |
| guozh...@apache.org |
kafka git commit: KAFKA-4528: Fix failure in ProducerTest.testAsyncSendCanCorrectlyFailWithTimeout |
Tue, 03 Jan, 17:11 |
| guozh...@apache.org |
kafka-site git commit: HOTFIX: MINOR: Remove duplicate list items. |
Wed, 04 Jan, 02:06 |
| guozh...@apache.org |
kafka git commit: KAFKA-4584: Fail the 'kafka-configs' command if the config to be removed does not exist |
Wed, 04 Jan, 05:41 |
| guozh...@apache.org |
kafka git commit: MINOR: Update JavaDoc for KTable helper interfaces |
Thu, 05 Jan, 19:27 |
| guozh...@apache.org |
kafka git commit: MINOR: update JavaDoc for simple helper interfaces of KStream and KTable operators |
Fri, 06 Jan, 16:24 |
| guozh...@apache.org |
[1/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
| guozh...@apache.org |
[2/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
| guozh...@apache.org |
[3/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
| guozh...@apache.org |
[4/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
| guozh...@apache.org |
[5/5] kafka git commit: KAFKA-3452: Support session windows |
Fri, 06 Jan, 18:12 |
| guozh...@apache.org |
kafka git commit: MINOR: cleanup Kafka Streams exception classes |
Fri, 06 Jan, 19:48 |
| guozh...@apache.org |
kafka git commit: KAFKA-4551: StreamsSmokeTest.test_streams intermittent failure |
Mon, 09 Jan, 19:13 |
| guozh...@apache.org |
kafka git commit: MINOR: some public JavaDoc cleanup |
Mon, 09 Jan, 23:17 |
| guozh...@apache.org |
kafka git commit: MINOR: Maybe decorate inner topics for SourceNode |
Tue, 10 Jan, 04:17 |
| guozh...@apache.org |
kafka git commit: MINOR: rename SessionStore.findSessionsToMerge to findSessions |
Tue, 10 Jan, 17:38 |
| guozh...@apache.org |
kafka git commit: MINOR: Replacing for with foreach loop in stream test classes |
Tue, 10 Jan, 19:53 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-4481: relax streams api type contraints |
Wed, 11 Jan, 17:11 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-4481: relax streams api type contraints |
Wed, 11 Jan, 17:11 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-4060: Remove zk client dependency in kafka streams |
Wed, 11 Jan, 17:15 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-4060: Remove zk client dependency in kafka streams |
Wed, 11 Jan, 17:15 |
| guozh...@apache.org |
kafka git commit: MINOR: Update rocksDB dependency to 5.0.1 |
Wed, 11 Jan, 17:37 |
| guozh...@apache.org |
[1/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
| guozh...@apache.org |
[2/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
| guozh...@apache.org |
[3/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 19:35 |
| guozh...@apache.org |
[1/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics [Forced Update!] |
Wed, 11 Jan, 20:06 |
| guozh...@apache.org |
[2/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 20:06 |
| guozh...@apache.org |
[3/3] kafka git commit: KAFKA-3715: Add granular metrics to Kafka Streams and add hierarhical logging levels to Metrics |
Wed, 11 Jan, 20:06 |
| guozh...@apache.org |
kafka git commit: KAFKA-4114: Allow different offset reset strategies |
Thu, 12 Jan, 04:30 |
| guozh...@apache.org |
kafka git commit: KAFKA-3452; Follow-up: Add SessionWindows |
Thu, 12 Jan, 04:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-4603: Fixed the argument of shell in doc |
Thu, 12 Jan, 19:25 |
| guozh...@apache.org |
[1/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
| guozh...@apache.org |
[2/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
| guozh...@apache.org |
[3/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
| guozh...@apache.org |
[4/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
| guozh...@apache.org |
[5/5] kafka git commit: KAFKA-4490: Add Global Table support to Kafka Streams |
Thu, 12 Jan, 19:46 |
| guozh...@apache.org |
kafka git commit: MINOR: fix JavaDoc in SegmentIterator |
Thu, 12 Jan, 23:44 |
| guozh...@apache.org |
kafka git commit: MINOR: make methods introduced in KAFKA-4490 consistent with KIP-100 |
Fri, 13 Jan, 00:20 |
| guozh...@apache.org |
kafka git commit: HOTFIX: Added another broker to smoke test |
Fri, 13 Jan, 19:11 |
| guozh...@apache.org |
kafka git commit: KAFKA-3739: Add no-arg constructor for WindowedSerdes in Streams |
Fri, 13 Jan, 19:13 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unnecessary store info from TopologyBuilder |
Fri, 13 Jan, 19:28 |
| guozh...@apache.org |
kafka git commit: KAFKA-4619: Dissallow to output records with unknown keys in TransformValues |
Mon, 16 Jan, 19:24 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unused constructor param from ProcessorStateManager |
Mon, 16 Jan, 19:40 |
| guozh...@apache.org |
kafka git commit: MINOR: Remove unused constructor param from ProcessorStateManager |
Tue, 17 Jan, 04:01 |
| guozh...@apache.org |
kafka git commit: KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable |
Tue, 17 Jan, 20:33 |
| guozh...@apache.org |
kafka git commit: KAFKA-4588: Wait for topics to be created in QueryableStateIntegrationTest.shouldNotMakeStoreAvailableUntilAllStoresAvailable |
Tue, 17 Jan, 20:33 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3452 Follow-up: Refactoring StateStore hierarchies |
Tue, 17 Jan, 22:13 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3452 Follow-up: Refactoring StateStore hierarchies |
Tue, 17 Jan, 22:13 |
| guozh...@apache.org |
[1/2] kafka git commit: KAFKA-3452 Follow-up: Refactoring StateStore hierarchies |
Tue, 17 Jan, 22:14 |
| guozh...@apache.org |
[2/2] kafka git commit: KAFKA-3452 Follow-up: Refactoring StateStore hierarchies |
Tue, 17 Jan, 22:14 |
| guozh...@apache.org |
kafka git commit: MINOR: remove ZK from system tests |
Wed, 18 Jan, 02:14 |
| guozh...@apache.org |
kafka git commit: HOTFIX: ChangeLoggingKeyValueStore.name() returns null |
Wed, 18 Jan, 17:19 |
| guozh...@apache.org |
kafka git commit: HOTFIX: ChangeLoggingKeyValueStore.name() returns null |
Wed, 18 Jan, 17:19 |
| guozh...@apache.org |
kafka git commit: MINOR: refactor streams system test class hierachy |
Wed, 18 Jan, 19:55 |
| guozh...@apache.org |
kafka git commit: MINOR: refactor streams system test class hierachy |
Wed, 18 Jan, 19:55 |
| guozh...@apache.org |
kafka git commit: KAFKA-4060; Follow-up: Throw exceptions when internal topics to create already exist with unexpected number of partitions |
Wed, 18 Jan, 23:54 |
| guozh...@apache.org |
kafka git commit: KAFKA-4060; Follow-up: Throw exceptions when internal topics to create already exist with unexpected number of partitions |
Wed, 18 Jan, 23:54 |
| guozh...@apache.org |
kafka git commit: MINOR: reduce verbosity of cache flushes |
Fri, 20 Jan, 19:08 |
| guozh...@apache.org |
kafka git commit: MINOR: reduce verbosity of cache flushes |
Fri, 20 Jan, 19:08 |
| guozh...@apache.org |
kafka git commit: KAFKA-4060 and KAFKA-4476 follow up: remove unnecessary InternalTopicManager branch and fixed one copartitioning bug |
Sat, 21 Jan, 21:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-4060 and KAFKA-4476 follow up: remove unnecessary InternalTopicManager branch and fixed one copartitioning bug |
Sat, 21 Jan, 21:18 |
| guozh...@apache.org |
kafka git commit: KAFKA-4672; fix source compatibility for lambda expressions |
Sat, 21 Jan, 22:10 |
| guozh...@apache.org |
kafka git commit: KAFKA-4672; fix source compatibility for lambda expressions |
Sat, 21 Jan, 22:10 |
| guozh...@apache.org |
kafka git commit: HOTFIX: KAFKA-4060 and KAFKA-4476 follow up |
Mon, 23 Jan, 17:34 |
| guozh...@apache.org |
kafka git commit: HOTFIX: KAFKA-4060 and KAFKA-4476 follow up |
Mon, 23 Jan, 17:35 |
| guozh...@apache.org |
kafka git commit: KAFKA-4060 Follow-up: update docs accordingly |
Mon, 23 Jan, 18:21 |