| damian...@apache.org |
[kafka] branch trunk updated: MINOR: Add documentation for KAFKA-6086 (ProductionExceptionHandler) (#4395) |
Mon, 08 Jan, 11:33 |
| damian...@apache.org |
[kafka] branch trunk updated: KAFKA-6412 Improve synchronization in CachingKeyValueStore methods |
Wed, 10 Jan, 10:24 |
| damian...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6378 KStream-GlobalKTable null KeyValueMapper handling |
Wed, 31 Jan, 10:21 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-4335: Add batch.size to FileStreamSource connector to prevent OOM |
Sat, 06 Jan, 02:32 |
| ewe...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6252; Close the metric group to clean up any existing metrics |
Sat, 06 Jan, 05:23 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6252; Close the metric group to clean up any existing metrics |
Sat, 06 Jan, 05:24 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6277: Ensure loadClass for plugin class loaders is thread-safe. |
Mon, 22 Jan, 03:41 |
| ewe...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6277: Ensure loadClass for plugin class loaders is thread-safe. |
Mon, 22 Jan, 03:41 |
| ewe...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6277: Ensure loadClass for plugin class loaders is thread-safe. |
Mon, 22 Jan, 03:42 |
| ewe...@apache.org |
[kafka] branch trunk updated: MINOR: Add async and different sync startup modes in connect service test class |
Mon, 22 Jan, 23:00 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-4029: SSL support for Connect REST API (KIP-208) |
Tue, 30 Jan, 23:09 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6018: Make KafkaFuture.Future an interface (KIP-218) |
Tue, 30 Jan, 23:56 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-4930: Enforce set of legal characters for connector names (KIP-212) |
Wed, 31 Jan, 16:49 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-5142: Add Connect support for message headers (KIP-145) |
Wed, 31 Jan, 18:40 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6383: complete shutdown for CREATED StreamThreads (#4343) |
Tue, 02 Jan, 17:32 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5368: Add test for skipped-records metric (#4365) |
Tue, 02 Jan, 17:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6269: KTable restore fails after rebalance (#4300) |
Tue, 02 Jan, 17:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: Fix wrong property mentioned in doc; Author: Praveen K Palaniswamy <yourspraveen@gmail.com> |
Tue, 02 Jan, 18:08 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6391 ensure topics are created with correct partitions BEFORE building the… (#4347) |
Tue, 02 Jan, 18:22 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6269: KTable restore fails after rebalance (#4300) |
Tue, 02 Jan, 18:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6318: StreamsResetter should return non-zero return code on error (#4305) |
Tue, 02 Jan, 18:46 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: refactored code duplicates in several files (Streams project) (#4357) |
Tue, 02 Jan, 18:54 |
| guozh...@apache.org |
[kafka] branch trunk updated: Revert "KAFKA-6383: complete shutdown for CREATED StreamThreads (#4343)" |
Tue, 02 Jan, 22:22 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: MINOR: Temporarily disable flaky Streams EOS system tests (#4355) |
Wed, 03 Jan, 17:25 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6256: fix flaky test KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache |
Wed, 03 Jan, 19:08 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6256: fix flaky test KStreamKTableJoinIntegrationTest.shouldCountClicksPerRegionWithNonZeroByteCache |
Wed, 03 Jan, 19:09 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: fix image 404s in streams doc |
Mon, 08 Jan, 17:39 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated (1382654 -> 59974aa) |
Mon, 08 Jan, 17:42 |
| guozh...@apache.org |
[kafka-site] 01/01: Merge pull request #114 from joel-hamill/fix-image-404 |
Mon, 08 Jan, 17:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Improve exception messages when state stores cannot be accessed. (#4383) |
Mon, 08 Jan, 19:14 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix menu ordering in streams docs |
Mon, 08 Jan, 19:43 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6363: Use MockAdminClient for any unit tests that depend on AdminClient (#4371) |
Mon, 08 Jan, 19:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: Updating docs for streams app reset tool (#4401) |
Mon, 08 Jan, 20:02 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: Fix Streams navigation, menu order, and missig maven content (#4403) |
Tue, 09 Jan, 17:24 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: Menu order in Streams docs incorrect (#115) |
Tue, 09 Jan, 22:25 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Menu updates and navigation (#4405) |
Wed, 10 Jan, 00:28 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6398: fix KTable.filter that does not include its parent's queryable storename |
Wed, 10 Jan, 19:14 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6398: fix KTable.filter that does not include its parent's queryable storename |
Wed, 10 Jan, 19:16 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6383: Complete shut down for streams threads that have not started |
Thu, 11 Jan, 00:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6265: Add #queryableStoreName() to GlobalKTable |
Thu, 11 Jan, 17:54 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Improve Join integration test coverage, PART I |
Fri, 12 Jan, 23:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: 4385 |
Sat, 13 Jan, 01:28 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: Update kafka-site information (#116) |
Sat, 13 Jan, 02:48 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: Fix typo (#118) |
Tue, 16 Jan, 18:29 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: MINOR: Fix typo (#4426) |
Tue, 16 Jan, 18:30 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix typo (#4426) |
Tue, 16 Jan, 18:30 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-4218: Enable access to key in ValueTransformer and ValueMapper |
Tue, 16 Jan, 18:47 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Improve Join integration test coverage, PART II |
Tue, 16 Jan, 23:13 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6328: Sort node groups considering global stores in InternalTopologyBuilder#makeNodeGroups |
Wed, 17 Jan, 00:57 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: Adding anchor link to Streams Use Case (#117) |
Wed, 17 Jan, 18:10 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Need to get a new transformer for each get() call. can't share'em (#4435) |
Thu, 18 Jan, 16:45 |
| guozh...@apache.org |
[kafka] branch trunk updated: improve internal topic integration test (#4437) |
Thu, 18 Jan, 16:57 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: Streams Use case anchor (#120) |
Thu, 18 Jan, 17:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: Streams Use case anchor (#4420) |
Thu, 18 Jan, 17:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6398: Return value getter based on KTable materialization status |
Thu, 18 Jan, 21:12 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6398: Return value getter based on KTable materialization status |
Thu, 18 Jan, 21:15 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Improve on reset integration test (#4436) |
Thu, 18 Jan, 21:55 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: update docs with regard to improved resilience of Kafka Streams (#4380) |
Mon, 22 Jan, 22:37 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: increase timeout for unstable KTableSourceTopicRestartIntegrationTest (#4445) |
Mon, 22 Jan, 22:38 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: Adding new logo to Powered By Page - Amadeus (#121) |
Tue, 23 Jan, 23:02 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6461 TableTableJoinIntegrationTest is unstable if caching is enabled (#4451) |
Tue, 23 Jan, 23:21 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR Added hypen (#122) |
Wed, 24 Jan, 04:41 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6462: fix unstable ResetIntegrationTest (#4446) |
Wed, 24 Jan, 21:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: update upgrade notes with regard to KIP-149 (#4439) |
Fri, 26 Jan, 17:18 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6205: initialize topology after state stores restoration completed |
Fri, 26 Jan, 17:35 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6205: initialize topology after state stores restoration completed |
Fri, 26 Jan, 18:09 |
| guozh...@apache.org |
[kafka] branch trunk updated: Add missing backslash (#4474) |
Fri, 26 Jan, 18:14 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fixed a few typos in configs and streams docs (#4452) |
Fri, 26 Jan, 18:40 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: update javadocs for serde (#3047) |
Fri, 26 Jan, 18:49 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: a single doc typo (#2969) |
Fri, 26 Jan, 19:15 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: fix command help description on zookeeper host strings URLs (#2940) |
Fri, 26 Jan, 19:17 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix comment on how to consume __consumer_offsets (#3710) |
Fri, 26 Jan, 19:29 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Changed javadoc on KafkaConsumer#endOffsets (#3470) |
Fri, 26 Jan, 19:31 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: JavaDoc improvements for RangeAssignor (#4079) |
Fri, 26 Jan, 19:35 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Add authorizer.class.name to the security section in documentation (#4310) |
Fri, 26 Jan, 19:40 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Replace empty string concattenation with String.valueOf() where possible. (#4369) |
Fri, 26 Jan, 19:43 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Optimize KTable-KTable join value getter supplier (#4458) |
Mon, 29 Jan, 04:17 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: MINOR: Fix some streams web doc nits (#4411) |
Mon, 29 Jan, 18:08 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix some streams web doc nits (#4411) |
Mon, 29 Jan, 18:10 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-3625: Add public test utils for Kafka Streams (#4402) |
Tue, 30 Jan, 01:21 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6451: Simplifying KStreamReduce and KStreamAggregate |
Tue, 30 Jan, 01:38 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Code refacotring in KTable-KTable Join (#4486) |
Tue, 30 Jan, 01:48 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6166: Streams configuration requires consumer. and producer. in order to be read (#4434) |
Tue, 30 Jan, 18:18 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6166: Streams configuration requires consumer. and producer. in order to be read (#4434) |
Tue, 30 Jan, 18:29 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: HOTFIX: add missing changes in AbstractConfig for KAFKA-6166 |
Tue, 30 Jan, 18:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6166: Update javadoc for streams config (#4489) |
Tue, 30 Jan, 22:14 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-4969: Attempt to evenly distribute load of tasks (#4410) |
Tue, 30 Jan, 23:31 |
| guozh...@apache.org |
[kafka] branch 1.0 updated: KAFKA-4969: Attempt to evenly distribute load of tasks (#4410) |
Tue, 30 Jan, 23:35 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: ignore reset integration tests |
Wed, 31 Jan, 01:23 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307) |
Mon, 01 Jan, 10:16 |
| ij...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307) |
Mon, 01 Jan, 10:23 |
| ij...@apache.org |
[kafka] branch trunk updated: Replace Arrays.asList with Collections.singletonList where possible (#4368) |
Mon, 01 Jan, 13:07 |
| ij...@apache.org |
[kafka] branch trunk updated (9b32639 -> a7e4902) |
Mon, 08 Jan, 12:14 |
| ij...@apache.org |
[kafka] 01/01: MINOR: Catch JsonMappingException subclass (#3821) |
Mon, 08 Jan, 12:14 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6298; Added support for location aware logger which fixes log line numbers (#4311) |
Thu, 04 Jan, 16:59 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Fix concurrency bug in MetadataCache and Metadata request when listeners inconsistent (#4374) |
Thu, 04 Jan, 18:16 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6311: Expose Kafka cluster ID in Connect REST API (KIP-238) (#4314) |
Fri, 05 Jan, 15:52 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6422 Mirror maker will throw null pointer exception when the message value is null (#4387) |
Mon, 08 Jan, 22:59 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6422 Mirror maker will throw null pointer exception when the message value is null (#4387) |
Mon, 08 Jan, 23:04 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6096: Add multi-threaded tests for group coordinator, txn manager (#4122) |
Tue, 09 Jan, 00:15 |