Saksham/demoqa fixes (#7989)

GitOrigin-RevId: 6a54fe6d5bfc293c018dba3ccdc5cd2601f25786
pathwaycom · Jan 30, 2025 · df76583 · df76583
1 parent 4120db6
commit df76583
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/docs/2.developers/4.user-guide/10.introduction/50.concepts.md b/docs/2.developers/4.user-guide/10.introduction/50.concepts.md
@@ -309,7 +309,7 @@ class InputSchema(pw.Schema):
 input_table = pw.io.kafka.read(kafka_settings, schema=InputSchema, topic="topic1", format="json")
 filtered_table = input_table.filter(input_table.age >= 0)
 result_table = filtered_table.reduce(sum_age = pw.reducers.sum(filtered_table.age))
-pw.io.kafka.write(table, kafka_settings, topic="topic2", format="json")
+pw.io.kafka.write(result_table, kafka_settings, topic="topic2", format="json")
 
 pw.run()
 ```