You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by te...@apache.org on 2022/10/17 03:02:49 UTC
[pulsar] branch branch-2.11 updated: [improve][test] Add test case for system topic schema not compatible bug. (#17992)
This is an automated email from the ASF dual-hosted git repository.
technoboy pushed a commit to branch branch-2.11
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-2.11 by this push:
new d7cef4bda08 [improve][test] Add test case for system topic schema not compatible bug. (#17992)
d7cef4bda08 is described below
commit d7cef4bda08d0ab6513b7b028996046eb7423536
Author: Shen Liu <li...@126.com>
AuthorDate: Mon Oct 17 10:59:03 2022 +0800
[improve][test] Add test case for system topic schema not compatible bug. (#17992)
Co-authored-by: druidliu <dr...@tencent.com>
---
.../systopic/NamespaceEventsSystemTopicServiceTest.java | 13 +++++++++++++
1 file changed, 13 insertions(+)
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java
index 244d7587a42..15463977d5e 100644
--- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java
+++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/systopic/NamespaceEventsSystemTopicServiceTest.java
@@ -18,11 +18,14 @@
*/
package org.apache.pulsar.broker.systopic;
+import static org.mockito.Mockito.mock;
import com.google.common.collect.Sets;
import lombok.Cleanup;
+import org.apache.bookkeeper.mledger.ManagedLedger;
import org.apache.pulsar.broker.auth.MockedPulsarServiceBaseTest;
import org.apache.pulsar.broker.service.BrokerService;
import org.apache.pulsar.broker.service.persistent.PersistentTopic;
+import org.apache.pulsar.broker.service.persistent.SystemTopic;
import org.apache.pulsar.client.admin.PulsarAdminException;
import org.apache.pulsar.client.api.Message;
import org.apache.pulsar.client.api.MessageId;
@@ -89,6 +92,16 @@ public class NamespaceEventsSystemTopicServiceTest extends MockedPulsarServiceBa
Assert.assertEquals(SchemaCompatibilityStrategy.ALWAYS_COMPATIBLE, topic.getSchemaCompatibilityStrategy());
}
+ @Test
+ public void testSystemTopicSchemaCompatibility() throws Exception {
+ TopicPoliciesSystemTopicClient systemTopicClientForNamespace1 = systemTopicFactory
+ .createTopicPoliciesSystemTopicClient(NamespaceName.get(NAMESPACE1));
+ String topicName = systemTopicClientForNamespace1.getTopicName().toString();
+ SystemTopic topic = new SystemTopic(topicName, mock(ManagedLedger.class), pulsar.getBrokerService());
+
+ Assert.assertEquals(SchemaCompatibilityStrategy.ALWAYS_COMPATIBLE, topic.getSchemaCompatibilityStrategy());
+ }
+
@Test
public void testSendAndReceiveNamespaceEvents() throws Exception {
TopicPoliciesSystemTopicClient systemTopicClientForNamespace1 = systemTopicFactory