Skip to content
Discussion options

You must be logged in to vote

Example of producing different schemas to the same topic and consuming them:

@Test
public void testConsumeMultipleSchemaMessages() throws Exception {
final String namespace = "test-namespace-" + randomName(16);
String ns = PUBLIC_TENANT + "/" + namespace;
admin.namespaces().createNamespace(ns, Sets.newHashSet(CLUSTER_NAME));
admin.namespaces().setSchemaCompatibilityStrategy(ns, SchemaCompatibilityStrategy.ALWAYS_COMPATIBLE);
final String autoProducerTopic = getTopicName(ns, "auto_produce_topic");
Producer<byte[]> autoProducer = pulsa…

Replies: 1 comment

Comment options

You must be logged in to vote
0 replies
Answer selected by guofengzh
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Category
Q&A
Labels
None yet
2 participants