| bbej...@apache.org |
[kafka] branch 2.0 updated: KAFKA-8011: Fix for race condition causing concurrent modification exception (#6338) |
Fri, 01 Mar, 00:08 |
| bbej...@apache.org |
[kafka] branch 1.1 updated: Fixing merge conflicts from cherry pick |
Fri, 01 Mar, 00:20 |
| bbej...@apache.org |
[kafka] branch 1.0 updated: KAFKA-8011: Fix for race condition causing concurrent modification exception (#6338) |
Fri, 01 Mar, 00:27 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-8012; Ensure partitionStates have not been removed before truncating. (#6333) |
Fri, 01 Mar, 00:37 |
| j...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8012; Ensure partitionStates have not been removed before truncating. (#6333) |
Fri, 01 Mar, 00:51 |
| j...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8012; Ensure partitionStates have not been removed before truncating. (#6333) |
Fri, 01 Mar, 00:55 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7918: Inline generic parameters Pt. III: in-memory window store (#6328) |
Fri, 01 Mar, 01:39 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7922: Return authorized operations in describe consumer group responses (KIP-430 Part-1) |
Fri, 01 Mar, 15:54 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: ConsumerNetworkClient does not need to send the remaining requests when the node is not ready (#6264) |
Fri, 01 Mar, 16:55 |
| guozh...@apache.org |
[kafka] branch trunk updated (caecc16 -> 057bb35) |
Fri, 01 Mar, 19:22 |
| guozh...@apache.org |
[kafka] branch 2.2 updated: HOTFIX: add igore import to streams_upgrade_test |
Fri, 01 Mar, 19:24 |
| guozh...@apache.org |
[kafka] branch 2.0 updated: HOTFIX: add igore import to streams_upgrade_test |
Fri, 01 Mar, 19:25 |
| guozh...@apache.org |
[kafka] branch 1.1 updated: HOTFIX: add igore import to streams_upgrade_test |
Fri, 01 Mar, 19:25 |
| mj...@apache.org |
[kafka] annotated tag 2.2.0-rc1 updated (87ed5d3 -> faa82df) |
Fri, 01 Mar, 19:35 |
| mj...@apache.org |
[kafka-site] branch asf-site updated: Update 2.2 docs with RC1 fixes |
Fri, 01 Mar, 19:44 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7997: Use automatic RPC generation in SaslAuthenticate |
Sat, 02 Mar, 15:58 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceClose |
Mon, 04 Mar, 19:08 |
| maniku...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceClose |
Mon, 04 Mar, 19:11 |
| maniku...@apache.org |
[kafka] branch 2.1 updated: KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceClose |
Mon, 04 Mar, 19:11 |
| maniku...@apache.org |
[kafka] branch 2.0 updated: KAFKA-7312: Change broker port used in testMinimumRequestTimeouts and testForceClose |
Mon, 04 Mar, 19:12 |
| j...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8002: Log dir reassignment stalls if future replica has different segment base offset (#6364) |
Mon, 04 Mar, 21:28 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-8002: Log dir reassignment stalls if future replica has different segment base offset (#6364) |
Mon, 04 Mar, 22:12 |
| j...@apache.org |
[kafka] branch 1.1 updated: KAFKA-8002: Log dir reassignment stalls if future replica has different segment base offset (#6364) |
Mon, 04 Mar, 22:51 |
| rha...@apache.org |
[kafka] branch trunk updated: improve some logging statements (#6078) |
Mon, 04 Mar, 23:57 |
| rha...@apache.org |
[kafka] branch trunk updated: KAFKA-7880:Naming worker thread by task id (#6275) |
Tue, 05 Mar, 00:04 |
| bbej...@apache.org |
[kafka] branch 2.1 updated: KAFKA-7895: fix stream-time reckoning for Suppress (2.1) (#6286) (#6325) |
Tue, 05 Mar, 19:36 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Log exception thrown by consumer.poll() in VerifiableConsumer (#6368) |
Wed, 06 Mar, 02:12 |
| j...@apache.org |
[kafka] branch 2.2 updated: MINOR: Log exception thrown by consumer.poll() in VerifiableConsumer (#6368) |
Wed, 06 Mar, 02:44 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7976 - Fix DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable (#6374) |
Wed, 06 Mar, 09:55 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7976 - Fix DynamicBrokerReconfigurationTest.testUncleanLeaderElectionEnable (#6374) |
Wed, 06 Mar, 12:59 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7979 - Clean up threads and increase timeout in PartitionTest (#6378) |
Wed, 06 Mar, 14:13 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7979 - Clean up threads and increase timeout in PartitionTest (#6378) |
Wed, 06 Mar, 14:18 |
| bbej...@apache.org |
[kafka] branch trunk updated: Moved 'expired-window-' and 'late-' record-drop to StreamsMetricsImpl (#6355) |
Wed, 06 Mar, 17:18 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-8038 - Fix timing issue in SslTransportLayerTest.testCloseSsl (#6377) |
Wed, 06 Mar, 17:33 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8038 - Fix timing issue in SslTransportLayerTest.testCloseSsl (#6377) |
Wed, 06 Mar, 17:45 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7736; Consolidate Map usages in TransactionManager (#6270) |
Wed, 06 Mar, 17:52 |
| bbej...@apache.org |
[kafka] branch trunk updated: Fixed docs regarding caching default (#6375) |
Wed, 06 Mar, 18:54 |
| mj...@apache.org |
[kafka] branch trunk updated: KAFKA-8006: Guard calls to init and close from global processor (#6353) |
Wed, 06 Mar, 18:56 |
| bbej...@apache.org |
[kafka] branch trunk updated: KAFKA-8007: Avoid copying on fetch in InMemoryWindowStore (#6335) |
Wed, 06 Mar, 19:02 |
| mj...@apache.org |
[kafka] branch trunk updated: KAFKA-3522: Add public interfaces for timestamped stores (#6175) |
Wed, 06 Mar, 22:57 |
| mj...@apache.org |
[kafka] branch kafka-3522-rocksdb-format-windowstore-runtime created (now b03a811) |
Thu, 07 Mar, 01:25 |
| mj...@apache.org |
[kafka] 01/01: KAFKA-3522: Add TimestampedWindowStore builder/runtime classes |
Thu, 07 Mar, 01:25 |
| mj...@apache.org |
[kafka] branch kafka-3522-rocksdb-format-windowstore-runtime deleted (was b03a811) |
Thu, 07 Mar, 01:25 |
| bbej...@apache.org |
[kafka] branch trunk updated: MINOR: improve JavaDocs about global state stores (#6359) |
Thu, 07 Mar, 02:19 |
| cmcc...@apache.org |
[kafka] branch trunk updated: Fix for KAFKA-7974: Avoid zombie AdminClient when node host isn't resolvable (#6305) |
Thu, 07 Mar, 08:07 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-8018: Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed |
Thu, 07 Mar, 10:04 |
| maniku...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8018: Flaky Test SaslSslAdminClientIntegrationTest#testLegacyAclOpsNeverAffectOrReturnPrefixed |
Thu, 07 Mar, 10:07 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-8039 - Use MockTime in fast reauth test to avoid transient failures (#6383) |
Thu, 07 Mar, 13:22 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8039 - Use MockTime in fast reauth test to avoid transient failures (#6383) |
Thu, 07 Mar, 13:28 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7950; Update description for the "time" parameter for GetOffsetShell |
Thu, 07 Mar, 16:25 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7288 - Make sure no bytes buffered when relying on idle timeout in channel close test (#6390) |
Thu, 07 Mar, 18:10 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7288 - Make sure no bytes buffered when relying on idle timeout in channel close test (#6390) |
Thu, 07 Mar, 18:30 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-8061; Handle concurrent ProducerId reset and call to Sender thread shutdown (#6388) |
Thu, 07 Mar, 22:28 |
| j...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8061; Handle concurrent ProducerId reset and call to Sender thread shutdown (#6388) |
Thu, 07 Mar, 22:32 |
| bbej...@apache.org |
[kafka] branch trunk updated: Improve API docs of (flatT|t)ransform (#6365) |
Thu, 07 Mar, 22:42 |
| j...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8061; Handle concurrent ProducerId reset and call to Sender thread shutdown (#6388) |
Thu, 07 Mar, 22:45 |
| bbej...@apache.org |
[kafka] branch 2.2 updated: Improve API docs of (flatT|t)ransform (#6365) |
Thu, 07 Mar, 22:47 |
| guozh...@apache.org |
[kafka] branch trunk updated: Minor resolve streams scala warnings (#6369) |
Thu, 07 Mar, 23:05 |
| j...@apache.org |
[kafka] branch 2.0 updated: KAFKA-8061; Handle concurrent ProducerId reset and call to Sender thread shutdown (#6388) |
Thu, 07 Mar, 23:15 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-7831; Do not modify subscription state from background thread (#6221) |
Fri, 08 Mar, 00:29 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-8060: The Kafka protocol generator should allow null defaults |
Fri, 08 Mar, 03:55 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7980 - Fix timing issue in SocketServerTest.testConnectionRateLimit (#6391) |
Fri, 08 Mar, 14:37 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7980 - Fix timing issue in SocketServerTest.testConnectionRateLimit (#6391) |
Fri, 08 Mar, 14:43 |
| bbej...@apache.org |
[kafka] branch trunk updated: KAFKA-8040: Streams handle initTransactions timeout (#6372) |
Fri, 08 Mar, 15:29 |
| bbej...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8040: Streams handle initTransactions timeout (#6372) |
Fri, 08 Mar, 16:29 |
| bbej...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8040: Streams handle initTransactions timeout (#6372) |
Fri, 08 Mar, 16:31 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-8070: Increase consumer startup timeout in system tests (#6405) |
Fri, 08 Mar, 16:58 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8070: Increase consumer startup timeout in system tests (#6405) |
Fri, 08 Mar, 16:59 |
| j...@apache.org |
[kafka] branch trunk updated: KAFKA-8069; Fix early expiration of offsets due to invalid loading of expire timestamp (#6401) |
Fri, 08 Mar, 17:04 |
| j...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8069; Fix early expiration of offsets due to invalid loading of expire timestamp (#6401) |
Fri, 08 Mar, 17:13 |
| j...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8069; Fix early expiration of offsets due to invalid loading of expire timestamp (#6401) |
Fri, 08 Mar, 17:21 |
| bbej...@apache.org |
[kafka] branch trunk updated: KAFKA-3522: Add TimestampedWindowStore builder/runtime classes (#6173) |
Fri, 08 Mar, 17:30 |
| bbej...@apache.org |
[kafka] branch trunk updated: MINOR: cleanup deprectaion annotations (#6290) |
Fri, 08 Mar, 20:31 |
| bbej...@apache.org |
[kafka] branch 2.1 updated: HOT_FIX: Changes needed to correct cherry-pick (#6414) |
Sat, 09 Mar, 02:34 |
| mj...@apache.org |
[kafka] branch trunk updated: KAFKA-8065: restore original input record timestamp in forward() (#6393) |
Sat, 09 Mar, 03:24 |
| mj...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8065: restore original input record timestamp in forward() (#6393) |
Sat, 09 Mar, 03:32 |
| mj...@apache.org |
[kafka] branch 2.1 updated: KAFKA-8065: restore original input record timestamp in forward() (#6393) |
Sat, 09 Mar, 03:45 |
| mj...@apache.org |
[kafka] branch 2.0 updated: KAFKA-8065: restore original input record timestamp in forward() (#6393) |
Sat, 09 Mar, 03:57 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7288; Fix check in SelectorTest to wait for no buffered bytes (#6415) |
Sat, 09 Mar, 08:10 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7288; Fix check in SelectorTest to wait for no buffered bytes (#6415) |
Sat, 09 Mar, 08:15 |
| bbej...@apache.org |
[kafka] branch trunk updated: MINOR: fix Scala compiler warning (#6417) |
Sat, 09 Mar, 13:09 |
| mj...@apache.org |
[kafka] annotated tag 2.2.0-rc2 updated (05fcfde -> f29ee71) |
Sat, 09 Mar, 22:41 |
| mj...@apache.org |
[kafka-site] branch asf-site updated: MINOR: fix Streams config (#189) |
Sat, 09 Mar, 23:03 |
| maniku...@apache.org |
[kafka] branch trunk updated: MINOR: Print usage when parse fails during console producer |
Sun, 10 Mar, 06:50 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7922: Return authorized operations in Metadata request response (KIP-430 Part-2) |
Sun, 10 Mar, 12:00 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7939: Fix timing issue in KafkaAdminClientTest.testCreateTopicsRetryBackoff |
Mon, 11 Mar, 14:19 |
| maniku...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7939: Fix timing issue in KafkaAdminClientTest.testCreateTopicsRetryBackoff |
Mon, 11 Mar, 14:19 |
| maniku...@apache.org |
[kafka] branch trunk updated: MINOR: Update delete topics zk path in assertion error messages |
Mon, 11 Mar, 18:17 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-8091; Wait for processor shutdown before testing removed listeners (#6425) |
Mon, 11 Mar, 18:43 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-8091; Wait for processor shutdown before testing removed listeners (#6425) |
Mon, 11 Mar, 18:51 |
| bbej...@apache.org |
[kafka] branch 2.0 updated: KAFKA-8040: Streams handle initTransactions timeout (#6416) |
Mon, 11 Mar, 22:18 |
| maniku...@apache.org |
[kafka] branch trunk updated: KAFKA-7801: TopicCommand should not be able to alter transaction topic partition count |
Tue, 12 Mar, 06:06 |
| rsiva...@apache.org |
[kafka] branch trunk updated: KAFKA-7976; Update config before notifying controller of unclean leader update (#6426) |
Tue, 12 Mar, 09:47 |
| rsiva...@apache.org |
[kafka] branch 2.2 updated: KAFKA-7976; Update config before notifying controller of unclean leader update (#6426) |
Tue, 12 Mar, 09:53 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Change Trogdor agent's cleanup executor to a cached thread pool (#6309) |
Tue, 12 Mar, 15:32 |
| bbej...@apache.org |
[kafka] branch trunk updated: KAFKA-3522: add missing guards for TimestampedXxxStore (#6356) |
Tue, 12 Mar, 16:28 |
| guozh...@apache.org |
[kafka] branch trunk updated: KAFKA-7944: Improve Suppress test coverage (#6382) |
Tue, 12 Mar, 16:53 |
| mj...@apache.org |
[kafka] branch trunk updated: MINOR: Avoid double null check in KStream#transform() (#6429) |
Tue, 12 Mar, 18:06 |
| guozh...@apache.org |
[kafka] branch trunk updated: MINOR: Use Java 8 lambdas in KStreamImplTest (#6430) |
Tue, 12 Mar, 20:35 |
| j...@apache.org |
[kafka] branch trunk updated: MINOR: Better messaging for invalid fetch response (#6427) |
Tue, 12 Mar, 22:24 |