for avro, we use decode messages to get stream properties similar to JSON, we should directly use the avro schema to get stream properties

[github-actions]

olake/drivers/kafka/internal/kafka.go

Lines 150 to 153 in 20ea7a2

	// TODO: for avro, we use decode messages to get stream properties similar to JSON, we should directly use the avro schema to get stream properties
	func (k *Kafka) ProduceSchema(ctx context.Context, streamName string) (*types.Stream, error) {
	logger.Infof("producing schema for topic [%s]", streamName)
	stream := types.NewStream(streamName, "topics", nil)

---

This issue was generated by todo-issue based on a TODO comment in 20ea7a2. It's been assigned to @ImDoubD-datazip because they committed the code.