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
index 83259e40..492982eb 100644
--- 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()
 ```