| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-6526: Enable unclean leader election without controller change (#4920) |
Tue, 01 May, 14:27 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Removed unused imports in a few tests (#4938) |
Tue, 01 May, 22:27 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6825: Make StreamsConfig#DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG public (#4929) |
Wed, 02 May, 18:58 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6825: Make StreamsConfig#DEFAULT_PRODUCTION_EXCEPTION_HANDLER_CLASS_CONFIG public (#4929) |
Wed, 02 May, 18:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6657: Add StreamsConfig prefix for different consumers (#4805) |
Wed, 02 May, 20:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: Simplify ConsoleConsumer stripWithPrefix function |
Wed, 02 May, 20:32 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6829: retry commits on unknown topic or partition (#4948) |
Thu, 03 May, 00:01 |
| ij...@apache.org |
[kafka] branch trunk updated: Upgrade ZooKeeper to 3.4.12 and Scala to 2.12.6 (#4940) |
Thu, 03 May, 16:25 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6853: ZooKeeperRequestLatencyMs is incorrect (#4961) |
Thu, 03 May, 16:46 |
| ij...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6853: ZooKeeperRequestLatencyMs is incorrect (#4961) |
Thu, 03 May, 16:48 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:05 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:09 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6854; Handle batches deleted during log cleaning of logs with txns (#4962) |
Thu, 03 May, 20:12 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 06:06 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 07:48 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Fri, 04 May, 15:30 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6761: Part 1 of 3; Graph nodes (#4923) |
Fri, 04 May, 15:40 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Removed deprecated schedule function (#4908) |
Fri, 04 May, 15:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5697: issue Consumer#wakeup during Streams shutdown |
Fri, 04 May, 16:06 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: [KAFKA-6861] Missing ')' in Kafka Streams documentation (#139) |
Fri, 04 May, 16:54 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: fix tutorial example code snippet |
Fri, 04 May, 16:58 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: fix streams tutorial code example |
Fri, 04 May, 16:59 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6844: Call shutdown on GlobalStreamThread after all StreamThreads have stopped (#4950) |
Fri, 04 May, 22:18 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6867; Corrected the typos in upgrade.html (#4970) |
Fri, 04 May, 22:42 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove KafkaStreams#toString (#4909) |
Fri, 04 May, 23:35 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Build and code sample updates for Kafka Streams DSL for Scala (#4949) |
Mon, 07 May, 03:55 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6474: Rewrite tests to use new public TopologyTestDriver [cleanup] (#4939) |
Mon, 07 May, 16:21 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated parameter in ProcessorContext#register (#4911) |
Mon, 07 May, 16:22 |
| mj...@apache.org |
[kafka] branch trunk updated: KAFKA-6871: KStreams Scala API: incorrect Javadocs and misleading parameter name (#4971) |
Mon, 07 May, 16:27 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated KTable#writeAs, print, foreach, to, through (#4910) |
Mon, 07 May, 16:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6628: RocksDBSegmentedBytesStoreTest does not cover time window serdes (#4836) |
Mon, 07 May, 17:57 |
| guozh...@apache.org |
[kafka-site] branch asf-site updated: MINOR: Fix typo in table (#140) |
Mon, 07 May, 19:48 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part I (#4919) |
Tue, 08 May, 00:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Make Serdes less confusing in Scala (#4963) |
Tue, 08 May, 16:15 |
| ij...@apache.org |
[kafka] branch trunk updated: KAFKA-6879; Invoke session init callbacks outside lock to avoid Controller deadlock (#4977) |
Tue, 08 May, 22:52 |
| ij...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6879; Invoke session init callbacks outside lock to avoid Controller deadlock (#4977) |
Tue, 08 May, 22:59 |
| mj...@apache.org |
[kafka] branch trunk updated: MINOR: add equals()/hashCode() for Produced/Consumed (#4979) |
Tue, 08 May, 23:07 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6292; Improve FileLogInputStream batch position checks to avoid type overflow (#4928) |
Wed, 09 May, 00:07 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6877; Remove completedFetch upon a failed parse if it contains no records. |
Wed, 09 May, 01:57 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Fix trace logging in ReplicaManager (#4916) |
Wed, 09 May, 06:02 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-6834: Handle compaction with batches bigger than max.message.bytes (#4953) |
Wed, 09 May, 10:46 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA 6673: Implemented missing override equals method (#4745) |
Wed, 09 May, 17:34 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6878: NPE when querying global state store not in READY state (#4978) |
Wed, 09 May, 17:42 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6878: NPE when querying global state store not in READY state (#4978) |
Wed, 09 May, 17:48 |
| mj...@apache.org |
[kafka] branch 1.1 updated: HOTFIX: remove empty line to pass checkstyle |
Wed, 09 May, 19:11 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6299; Fix AdminClient error handling when metadata changes (#4295) |
Wed, 09 May, 21:27 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6878 Switch the order of underlying.init and initInternal (#4988) |
Thu, 10 May, 00:06 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6878 Switch the order of underlying.init and initInternal (#4988) |
Thu, 10 May, 00:07 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part II (#4976) |
Thu, 10 May, 00:13 |
| jun...@apache.org |
[kafka] branch trunk updated: KAFKA-6361: Fix log divergence between leader and follower after fast leader fail over (#4882) |
Thu, 10 May, 01:50 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-6870 Concurrency conflicts in SampledStat (#4985) |
Thu, 10 May, 11:27 |
| rsiva...@apache.org |
[kafka] branch 1.1 updated (a7664f2 -> cf70366) |
Thu, 10 May, 12:13 |
| rsiva...@apache.org |
[kafka] 01/02: KAFKA-6765: Handle exception while reading throttle metric value in test (#4869) |
Thu, 10 May, 12:13 |
| rsiva...@apache.org |
[kafka] 02/02: KAFKA-6870 Concurrency conflicts in SampledStat (#4985) |
Thu, 10 May, 12:13 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Update dynamic broker configuration doc for truststore update (#4954) |
Thu, 10 May, 15:55 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove deprecated valueTransformer.punctuate (#4993) |
Thu, 10 May, 16:51 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Fix typo in ConsumerRebalanceListener JavaDoc (#4996) |
Thu, 10 May, 16:53 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) |
Thu, 10 May, 21:18 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6893; Create processors before starting acceptor in SocketServer (#4999) |
Thu, 10 May, 21:22 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6894: Improve err msg when connecting processor with global store (#5000) |
Thu, 10 May, 22:49 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: A few small cleanups in AdminClient from KAFKA-6299 (#4989) |
Fri, 11 May, 00:31 |
| ij...@apache.org |
[kafka] branch trunk updated: MINOR: Rename RecordFormat to RecordVersion (#4809) |
Fri, 11 May, 05:06 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5965: Remove Deprecated AdminClient from Streams Resetter Tool (#4968) |
Fri, 11 May, 15:44 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6394; Add a check to prevent misconfiguration of advertised listeners (#4897) |
Fri, 11 May, 15:49 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Count fix and Type alias refactor in Streams Scala API (#4966) |
Fri, 11 May, 17:15 |
| mj...@apache.org |
[kafka] branch trunk updated: MINOR - Fix typo in Streams Dev Guide (#4972) |
Fri, 11 May, 17:27 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6813: Remove deprecated APIs in KIP-182, Part III (#4991) |
Fri, 11 May, 18:38 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: RegexSourceIntegrationTest needs to cleanup shared output topic (#5008) |
Fri, 11 May, 20:53 |
| mj...@apache.org |
[kafka] branch trunk updated: MINOR: Ensure sensor names are unique in Kafka Streams (#5009) |
Sat, 12 May, 00:19 |
| ij...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6307: Fix KafkaMbean leak in JmxReporter (#4307) |
Mon, 14 May, 21:12 |
| ij...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6857; Leader should reply with undefined offset if undefined leader epoch requested (#4967) |
Mon, 14 May, 21:25 |
| lind...@apache.org |
[kafka] branch trunk updated: KAFKA-3473; More Controller Health Metrics (KIP-237) |
Tue, 15 May, 06:05 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6896: Add producer metrics exporting in KafkaStreams (#4998) |
Tue, 15 May, 21:29 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: doc change for deprecate removal (#5006) |
Wed, 16 May, 03:26 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6905: Document that Processors may be re-used by Streams (#5022) |
Wed, 16 May, 20:10 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: fix broken links in streams doc (#5025) |
Wed, 16 May, 20:23 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: MINOR: fix broken links in streams doc (#5025) |
Wed, 16 May, 20:24 |
| mj...@apache.org |
[kafka] branch trunk updated: MINOR: add missing parameter `processing.guaratees` to Streams docs (#5023) |
Wed, 16 May, 20:58 |
| mj...@apache.org |
[kafka] branch 1.1 updated: MINOR: add missing parameter `processing.guaratees` to Streams docs (#5023) |
Wed, 16 May, 21:00 |
| mj...@apache.org |
[kafka] branch 1.0 updated: MINOR: add missing parameter `processing.guaratees` to Streams docs (#5023) |
Wed, 16 May, 21:03 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Use Set instead of List for multiple topics (#5024) |
Thu, 17 May, 15:45 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6729: Reuse source topics for source KTable's materialized store's changelog (#5017) |
Thu, 17 May, 18:28 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: move Conusmed to o.a.k.streams.kstream (#5033) |
Thu, 17 May, 18:56 |
| guozh...@apache.org |
[kafka] branch trunk updated: HOTFIX: use ConsumedInternal in StreamsBuilder |
Fri, 18 May, 00:20 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-5697: revert wakeup-based impl (#5035) |
Fri, 18 May, 15:05 |
| ewe...@apache.org |
[kafka] branch trunk updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:40 |
| ewe...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:41 |
| ewe...@apache.org |
[kafka] branch 0.10.2 updated: KAFKA-6566: Improve Connect Resource Cleanup |
Fri, 18 May, 17:45 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Remove unused class (#5037) |
Fri, 18 May, 17:58 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036) |
Fri, 18 May, 20:30 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036) |
Fri, 18 May, 20:34 |
| j...@apache.org |
[kafka] branch 1.0 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036) |
Fri, 18 May, 20:41 |
| j...@apache.org |
[kafka] branch 0.11.0 updated: KAFKA-6917; Process txn completion asynchronously to avoid deadlock (#5036) |
Fri, 18 May, 20:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6849: add transformValues methods to KTable. (#4959) |
Fri, 18 May, 23:06 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6905: Document that Transformers may be re-used by Streams (#5026) |
Sun, 20 May, 01:44 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-6729: Follow up; disable logging for source KTable. (#5038) |
Sun, 20 May, 17:24 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Fix type inference on joins and aggregates (#5019) |
Sun, 20 May, 23:25 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: MINOR: Do not start processor for bounce-at-start (#4639) |
Mon, 21 May, 01:25 |