@@ -263,16 +263,20 @@ sealed class MyMessage {
263263// Create a MessageRegistry instance for MyMessage types
264264val registry = MessageRegistry <MyMessage >().apply {
265265 // Register each subtype with a unique type identifier and its serializer.
266- register(MyMessage .TextMessage ::class , " text " , MyMessage .TextMessage .serializer())
267- register(MyMessage .ImageMessage ::class , " image " , MyMessage .ImageMessage .serializer())
266+ register(MyMessage .TextMessage ::class , MyMessage .TextMessage .serializer())
267+ register(MyMessage .ImageMessage ::class , MyMessage .ImageMessage .serializer())
268268}
269269
270- // Example: Serializing a message using the registry
271- val json = Json { encodeDefaults = true }
272- val textMsg = MyMessage .TextMessage (" Hello, KCommand!" )
273- val (typeName, serializer) = registry.getTypeNameAndSerializer(textMsg::class )!!
274- val payload = json.encodeToString(serializer, textMsg)
275- println (" Type: $typeName , Serialized Payload: $payload " )
270+ // Example usage in the Kafka Streams transport
271+ val kafkaConfig = KafkaTransportConfig (
272+ applicationId = " my-kafka-app" ,
273+ bootstrapServers = " localhost:9092"
274+ )
275+
276+ val kafkaTransport = KafkaStreamsRemoteTransport <MyMessage , Any >(
277+ config = kafkaConfig,
278+ registry = registry,
279+ )
276280```
277281
278282## Contributing
0 commit comments